Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-82

Add the RocketMQ plugin for the Apache Flink

    Details

    • Type: Wish
    • Status: In Progress
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: rocketmq-externals
    • Labels:
      None

      Description

      A few basic data sources and sinks are built into Flink and are always available. The predefined data sources include reading from files, directories, and sockets, and ingesting data from collections and iterators. The predefined data sinks support writing to files, to stdout and stderr, and to sockets.

      The connector is the integration plugin for RocketMQ and Flink, some details in here,

      1. https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

      2. https://github.com/apache/rocketmq-externals/tree/master/rocketmq-flink

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                vesense Xin Wang
                Reporter:
                vongosling vongosling
              • Votes:
                1 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated: