You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Abhijeet Shukla <ab...@mindtree.com> on 2017/05/10 05:01:14 UTC

Camel kafka manual commit implementation

Hi Team,

I want to implement Kafka manual commit using apache camel, but not able to
find any clue to implement it its given only for auto commit. Kindly help me
out in the issue.

Thanks 
Abhijeet Shukla



--
View this message in context: http://camel.465427.n5.nabble.com/Camel-kafka-manual-commit-implementation-tp5799185.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel kafka manual commit implementation

Posted by Claus Ibsen <cl...@gmail.com>.
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
<ab...@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

Re: Camel kafka manual commit implementation

Posted by Abhijeet Shukla <ab...@mindtree.com>.
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.