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.
