[FLINK-20114][connector/kafka] Auto offset commit should be disabled …

…by default.
deepfield · Mar 29, 2021 · a4360c7 · a4360c7
1 parent 8de1784
commit a4360c7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java b/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
@@ -435,6 +435,7 @@ private void parseAndSetRequiredProperties() {
  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(),