[jira] [Created] (FLINK-19507) Native support for Apache Pulsar

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-19507) Native support for Apache Pulsar

Shang Yuanchun (Jira)
John Morrow created FLINK-19507:
-----------------------------------

             Summary: Native support for Apache Pulsar
                 Key: FLINK-19507
                 URL: https://issues.apache.org/jira/browse/FLINK-19507
             Project: Flink
          Issue Type: Wish
          Components: Stateful Functions
    Affects Versions: statefun-2.2.0
            Reporter: John Morrow


Flink StateFun has a sink/source IO module which can be used to plug in existing, or custom, Flink connectors that are not already integrated into a dedicated I/O module ([https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/io-module/flink-connectors.html|https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/io-module/flink-connectors.html).]).

Currently there are dedicated I/O modules for Apache Kafka and AWS Kinesis. It would be nice to add a similar one for Apache Pulsar.

 



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