From 181f01ee5246273e527d970326e3af69121d7352 Mon Sep 17 00:00:00 2001
From: Jast <745925668@qq.com>
Date: Fri, 7 Jun 2024 21:55:43 +0800
Subject: [PATCH] [Hotfix][Connector-V2][kafka]Kafka consumer group
 automatically commits offset logic error fix (#6961)

---
 .../connectors/seatunnel/kafka/source/KafkaConsumerThread.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
index 90d46bc502e..99b6baeaf16 100644
--- a/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
+++ b/seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaConsumerThread.java
@@ -45,7 +45,7 @@ public KafkaConsumerThread(KafkaSourceConfig kafkaSourceConfig, ConsumerMetadata
                         kafkaSourceConfig.getBootstrap(),
                         metadata.getConsumerGroup(),
                         kafkaSourceConfig.getProperties(),
-                        kafkaSourceConfig.isCommitOnCheckpoint());
+                        !kafkaSourceConfig.isCommitOnCheckpoint());
     }
 
     @Override