Hi Team,
I want to implement Kafka manual commit using apache camel, but not able to
find any clue to implement it its given only for auto commit. Kindly help me
out in the issue.
Thanks
Abhijeet Shukla
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-kafka-manual
I am trying to do so using camel router
as:
from("kafka:{{kafka.hostname}}:{{kafka.port}}?topic={{kafka.topic}}&groupId={{kafka.consumer.groupid}}&autoOffsetReset=none&autoCommitEnable=false&maxPollRecords=3").process(new
Processor() {
@Override