camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Camel kafka manual commit implementation
Date Thu, 11 May 2017 09:04:11 GMT
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.shukla@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

Mime
View raw message