Re: Camel kafka manual commit implementation

[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
                                        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.