Camel kafka manual commit implementation

2017-05-09 Thread Abhijeet Shukla
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

Re: Camel kafka manual commit implementation

2017-05-09 Thread Abhijeet Shukla
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