[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785947#comment-17785947
]
Márton Balassi commented on FLINK-33528:
----------------------------------------
[~pvary] is taking a stab at an example implementation for Kafka. We will
report back to see whether it is viable or if we need assistance.
> Externalize Python connector code
> ---------------------------------
>
> Key: FLINK-33528
> URL: https://issues.apache.org/jira/browse/FLINK-33528
> Project: Flink
> Issue Type: Technical Debt
> Components: API / Python, Connectors / Common
> Affects Versions: 1.18.0
> Reporter: Márton Balassi
> Priority: Major
> Fix For: 1.19.0
>
>
> During the connector externalization effort end to end tests for the python
> connectors were left in the main repository under:
> [https://github.com/apache/flink/tree/master/flink-python/pyflink/datastream/connectors]
> These include both python connector implementation and tests. Currently they
> depend on a previously released version of the underlying connectors,
> otherwise they would introduce a circular dependency given that they are in
> the flink repo at the moment.
> This setup prevents us from propagating any breaking change to PublicEvolving
> and Internal APIs used by the connectors as they lead to breaking the python
> e2e tests. We run into this while implementing FLINK-25857.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
