loserwang1024 opened a new pull request, #40: URL: https://github.com/apache/flink-connector-kafka/pull/40
### What is the purpose of the change As described in [FLIP-288](https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source), dynamic partition discovery is disabled by default, and users have to specify the interval of discovery in order to turn it on. It will be better if enable partition discovery by default. ### Brief change log - Kafka table source: "scan.topic-partition-discovery.interval" will be set to 5 minutes by default, aligned with the default value of ["metadata.max.age.ms" in Kafka consumer.](https://kafka.apache.org/documentation/#consumerconfigs_metadata.max.age.ms) - Kafka stream source: "partition.discovery.interval.ms" will be set to 5 minutes by default, with discovery interval set to 5 minutes. ### Verifying this change - See test unit. - Start flink with kafka source connector by default, then add kafka partition after a period of time to see if the new partition can be read. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
