You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Joey Pereira (Jira)" <ji...@apache.org> on 2025/05/28 15:28:00 UTC

[jira] [Created] (FLINK-37863) DynamicKafkaSource support in PyFlink

Joey Pereira created FLINK-37863:
------------------------------------

             Summary: 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


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)