[ROCKETMQ-82] Add the RocketMQ plugin for the Apache Flink

• Type: Wish
• Status: In Progress
• Priority: Minor
• Resolution: Unresolved
• Component/s: rocketmq-externals
• External issue URL: https://issues.apache.org/jira/browse/FLINK-5726
• Assignee: Xin Wang
• Reporter: Von Gosling
• Created: 07/Feb/17 04:00
• Updated: 20/Mar/18 15:06

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

Issue Links

• links to: GitHub Pull Request #45