You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by jq...@apache.org on 2021/03/29 23:53:34 UTC

[flink] 09/12: [FLINK-20114][connector/kafka] Auto offset commit should be disabled by default.

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

jqin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit a4360c7f4128eb7ec97c9707b184ab121e829312
Author: Dong Lin <li...@gmail.com>
AuthorDate: Sun Mar 7 23:05:02 2021 +0800

    [FLINK-20114][connector/kafka] Auto offset commit should be disabled by default.
---
 .../java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
index 73ba675..8ede378 100644
--- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
+++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
@@ -435,6 +435,7 @@ public class KafkaSourceBuilder<OUT> {
                 true);
         maybeOverride(
                 ConsumerConfig.GROUP_ID_CONFIG, "KafkaSource-" + new Random().nextLong(), false);
+        maybeOverride(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false", false);
         maybeOverride(
                 ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
                 startingOffsetsInitializer.getAutoOffsetResetStrategy().name().toLowerCase(),