Bowen Li created FLINK-38530:
--------------------------------
Summary: create python version of Dynamic Kafka Source
Key: FLINK-38530
URL: https://issues.apache.org/jira/browse/FLINK-38530
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: kafka-4.0.1, kafka-3.4.0, kafka-4.1.0
Reporter: Bowen Li
currently there's only java version of Dynamic Kafka Source, and cannot be used
in pyflink job
this ticket is for creating python version of Dynamic Kafka Source based on
porting of java version
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
