Hi everyone, I'm kicking off a workstream to enhance and productionize Flink DynamicKafkaSource, across areas of core imp, datastream/table/python APIs, etc
A few related tickets and PRs - Support per-cluster offset in Dynamic Kafka https://issues.apache.org/jira/browse/FLINK-38876 <https://issues.apache.org/jira/browse/FLINK-38876> - create Dynamic Kafka Source for pyflink https://issues.apache.org/jira/browse/FLINK-38530 - create Table source and factory for DynamicKafkaSource in Flink Table API https://issues.apache.org/jira/browse/FLINK-38920 Dian Fu has generously offered help to review python changes. If you're interested in contributing to the workstream, please let me know and feel free to jump in on any of the tickets or review PRs. Best, Bowen
