You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have created a custom CommonErrorHandler whose seeksAfterHandling returns false. I have ackMode = MANUAL_IMMEDIATE and enable.auto.commit = false. After handleOne returns true indicating that the record was recovered and the subsequent isAckAfterHandle call also returns true, I would expect the offset of the record to be committed, but it isn't. Is this a bug or by design?
Though I don't have a comprehensive understanding of KafkaMessageListenerContainer, I wonder if ackCurrent in commitOffsetsIfNeededAfterHandlingError should be called with this.isAnyManualAck instead of this.isManualAck.
If it is intentional that the offset is not committed, what would be the idiomatic way of getting it committed after successful error recovery in this setup?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
-
I have created a custom CommonErrorHandler whose seeksAfterHandling returns false. I have ackMode = MANUAL_IMMEDIATE and enable.auto.commit = false. After handleOne returns true indicating that the record was recovered and the subsequent isAckAfterHandle call also returns true, I would expect the offset of the record to be committed, but it isn't. Is this a bug or by design?
Though I don't have a comprehensive understanding of KafkaMessageListenerContainer, I wonder if ackCurrent in commitOffsetsIfNeededAfterHandlingError should be called with
this.isAnyManualAckinstead ofthis.isManualAck.If it is intentional that the offset is not committed, what would be the idiomatic way of getting it committed after successful error recovery in this setup?
Beta Was this translation helpful? Give feedback.
All reactions