Re: Camel kafka manual commit implementation

[Claus Ibsen]

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
 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

Camel kafka manual commit implementation

[Abhijeet Shukla]

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

[Abhijeet Shukla]

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.