I managed to play with the apache kafka commit offset classes and the ability to commit using the ConsumerConnector . I looked at the camel-kafka apache component, which has a consumer option like " autoCommitEnable ", the same as the auto.commit.enable property. Now is there any property or method in Camel Java DSL where, after using the message, we can perform manual offsets (using the provided methods or user parameters in the URL) OR should we use the Kafka Consumer API again to make consumer offsets?
source share