[
https://issues.apache.org/jira/browse/FLINK-37863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-37863:
----------------------------------
Assignee: Joey Pereira
> DynamicKafkaSource support in PyFlink
> -------------------------------------
>
> Key: FLINK-37863
> URL: https://issues.apache.org/jira/browse/FLINK-37863
> Project: Flink
> Issue Type: Improvement
> Components: API / Python, Connectors / Kafka
> Affects Versions: 2.0.0
> Reporter: Joey Pereira
> Assignee: Joey Pereira
> Priority: Minor
> Labels: pull-request-available
>
> The DynamicKafkaSource is not avaialble in PyFlink in the kafka connectors.
> Notably, the use of the KafkaMetadatService implementation will also require
> either:
> - Users to bring their own Java object implementing this
> - Shims for Pyflink (I'm not too familiar with whether this is easy or
> difficult)
> In addition, the documentation will need to be updated to include Python
> usage.
> cc [~shuyichen]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
