Hongshun Wang created FLINK-31953: ------------------------------------- Summary: FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source Key: FLINK-31953 URL: https://issues.apache.org/jira/browse/FLINK-31953 Project: Flink Issue Type: Improvement Components: Connectors / Kafka Reporter: Hongshun Wang Fix For: kafka-4.0.0
This improvement implements {{[[FLIP-288|https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source]|https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source]}} to enable partition discovery by default and set EARLIEST offset strategy for later discovered partitions. h4. -- This message was sent by Atlassian Jira (v8.20.10#820010)