Regarding Kafka Component Offset Auto Commit

[wriiblo <se...@gmail.com>]

Hi,

I have a few questions regarding Kafka component's offset management.

1) On the consumer side, there is a configuration called 'autoCommitEnable'
according to the documentation. (http://camel.apache.org/kafka.html) This
configuration seems synonymous to auto.commit.enable	described in Apache
Kafka documentation.
(http://kafka.apache.org/documentation.html#newconsumerconfigs)

It seems like that the Camel Kafka component's consumer still commit the
offset regardless whether autoCommitEnable configuration is set to false. 

Looking at the code of Camel Kafka component's KafkaConsumer, it seems like
this is thought out to be this way. (line 157-168 at
https://github.com/apache/camel/blob/camel-2.18.2/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java) 

Is there a reason why this is? Or is there another configuration that I need
to set to disable the automatic offset commit? I see that 2.19.0-SNAPSHOT
version has new updates regarding the offset management. 

2) Is there a way to set the consumer to a specific offset when using Kafka
component?

Thank you!





--
View this message in context: http://camel.465427.n5.nabble.com/Regarding-Kafka-Component-Offset-Auto-Commit-tp5795258.html
Sent from the Camel - Users mailing list archive at Nabble.com.