This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 372ec8c5372c8fc6637d3f7e2bcb21fff11d821e
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Jan 19 17:02:03 2024 +0100

    CAMEL-16044: do not enable auto-commit when using batching mode
---
 .../java/org/apache/camel/component/kafka/KafkaConfiguration.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 29e39132146..3cd48f37d4f 100755
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -740,7 +740,11 @@ public class KafkaConfiguration implements Cloneable, 
HeaderFilterStrategyAware
     }
 
     public boolean getAutoCommitEnable() {
-        return autoCommitEnable;
+        if (!batching) {
+            return autoCommitEnable;
+        }
+
+        return false;
     }
 
     /**

Reply via email to