[hotfix][connector/kafka] Remove the unused close.timeout.ms config.

deepfield · Mar 29, 2021 · b3471f2 · b3471f2
1 parent 4c6c423
commit b3471f2
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java b/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java
@@ -41,12 +41,6 @@ public class KafkaSourceOptions {
  "The interval in milliseconds for the Kafka source to discover "
  + "the new partitions. A non-positive value disables the partition discovery.");
 
- public static final ConfigOption<Long> CLOSE_TIMEOUT_MS =
- ConfigOptions.key("close.timeout.ms")
- .longType()
- .defaultValue(10000L)
- .withDescription("The max time to wait when closing components.");
-
  @SuppressWarnings("unchecked")
  public static <T> T getOption(
  Properties props, ConfigOption configOption, Function<String, T> parser) {