This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 181f01ee52 [Hotfix][Connector-V2][kafka]Kafka consumer group
automatically commits offset logic error fix (#6961)
181f01ee52 is described below
commit 181f01ee5246273e527d970326e3af69121d7352
Author: Jast <[email protected]>
AuthorDate: Fri Jun 7 21:55:43 2024 +0800
[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 90d46bc502..99b6baeaf1 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 class KafkaConsumerThread implements Runnable {
kafkaSourceConfig.getBootstrap(),
metadata.getConsumerGroup(),
kafkaSourceConfig.getProperties(),
- kafkaSourceConfig.isCommitOnCheckpoint());
+ !kafkaSourceConfig.isCommitOnCheckpoint());
}
@Override