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

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/22 08:21:00 UTC

[jira] [Updated] (FLINK-23651) Support RabbitMQ connectors in Python DataStream API

     [ https://issues.apache.org/jira/browse/FLINK-23651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu updated FLINK-23651:
----------------------------
    Fix Version/s: 1.15.0

> Support RabbitMQ connectors in Python DataStream API
> ----------------------------------------------------
>
>                 Key: FLINK-23651
>                 URL: https://issues.apache.org/jira/browse/FLINK-23651
>             Project: Flink
>          Issue Type: New Feature
>          Components: API / Python
>            Reporter: Eelis Kostiainen
>            Assignee: Eelis Kostiainen
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> Discrepancies between the Python and Java environments of Flink include lack of support for the RabbitMQ source and sink connectors. Py4J wrappers should be implemented for the connectors to support them in the Python API.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)