Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
3.21.2
-
None
-
-
Moderate
Description
Kafka offset advances when using Pausable kafka consumer and messages are lost when resumed.
Attached is the sample code
Also tried with
KafkaManualCommit manual = exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
manual.commit();