Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.18.3
-
Unknown
Description
Hi,
while attempting to add the circuit breaker pattern to a route (see also CAMEL-18759), I tried to use ThrottlingExceptionRoutePolicy to suspend and resume the route when a specific exception is thrown. I noticed that regardless of the breakOnFirstError setting, the message causing the circuit to be opened is lost. If breakOnFirstError is true, logs are showing "Will seek consumer to offset -1 and start polling again", but when the circuit is closed the message is not consumed. I suspect that the consumer overwrites the offset when it's suspended. If I switch to manual commits, everything works as expected.
Reproducer here: https://github.com/lorenzobenvenuti/camel-kafka-break-on-first-error-bug
Thanks,
lorenzo
Attachments
Issue Links
- causes
-
CAMEL-20089 camel-kafka: make breakOnFirstError more flexible
- Resolved
- is duplicated by
-
CAMEL-19358 camel-kafka - Kafka consumer is still able to consume message with keepOpen as true in ThrottlingExceptionRoutePolicy
- Resolved
- is related to
-
CAMEL-18588 Kafka consumer on any exception should repoll records after the committed offset
- Resolved
-
CAMEL-18759 camel-kafka - When Kafka pausable consumer is resumed, it reads all the messages from the earliest offset
- Resolved
- relates to
-
CAMEL-20044 camel-kafka - On rejoining consumer group Camel can set offset incorrectly causing messages to be replayed
- Resolved
-
CAMEL-19894 camel-kafka: enabling "breakOnFirstError" causes to skip records on exception
- Resolved