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.