How to implement a camel kafka manually?
Has anyone worked on manually committing Kafka using Apache camel, we don't find a hint for implementing it. We are trying to do this with a camel router:
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();
Please help us in this matter,
Thank you.
+3
source to share
No one has answered this question yet
See similar questions:
or similar: