Hi I dont think it supports manual commits. You are welcome to log a JIRA ticket so we can get this added http://camel.apache.org/support.html
On Wed, May 10, 2017 at 7:03 AM, Abhijeet Shukla <abhijeet.shu...@mindtree.com> wrote: > 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 > public void process(Exchange > exchange) throws Exception {.....}).end(); > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Camel-kafka-manual-commit-implementation-tp5799185p5799186.html > Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen ----------------- http://davsclaus.com @davsclaus Camel in Action 2: https://www.manning.com/ibsen2