duplicated block id: 1
size: 10 cleaned lines of code
in 2 files:
 - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java (306:317)
 - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java (578:589)