[ https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser updated FLINK-31953: ----------------------------------- Fix Version/s: kafka-3.1.0 (was: kafka-4.0.0) > 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 > Assignee: Hongshun Wang > Priority: Major > Labels: Connector, kafka-source, pull-request-available > Fix For: kafka-3.1.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]. > this Flip has there main objectives: > # Enable partition discovery by default. > # Provide a *EARLIEST* strategy for later discovered partitions. > # Organize the code logic of the current built-in OffsetsInitializer, then > modify the JavaDoc to let users know. > Each objective corresponds to a sub-task > h4. -- This message was sent by Atlassian Jira (v8.20.10#820010)