[camel] 02/03: CAMEL-18985: Updated `SyncCommitManager` to perform offsets auto-commit of the last `poll()` only if the auto-commit is enabled in the configuration.

[orpiske]

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

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

commit aaf7cc6254af09a380a21afc069996dabb87fdc2
Author: oleg_pershai <oleg_pers...@epam.com>
AuthorDate: Tue Apr 25 21:36:52 2023 +0100

    CAMEL-18985: Updated `SyncCommitManager` to perform offsets auto-commit of 
the last `poll()` only if the auto-commit is enabled in the configuration.
---
 .../apache/camel/component/kafka/consumer/SyncCommitManager.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java
index a494a8b10a6..9850e45d156 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/SyncCommitManager.java
@@ -46,8 +46,10 @@ public class SyncCommitManager extends AbstractCommitManager 
{
 
     @Override
     public void commit() {
-        LOG.info("Auto commitSync {} from {}", threadId, printableTopic);
-        consumer.commitSync();
+        if 
(kafkaConsumer.getEndpoint().getConfiguration().isAutoCommitEnable()) {
+            LOG.info("Auto commitSync {} from {}", threadId, printableTopic);
+            consumer.commitSync();
+        }
     }
 
     @Override