[ https://issues.apache.org/jira/browse/ROCKETMQ-82?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392439#comment-16392439 ]
ASF GitHub Bot commented on ROCKETMQ-82: ---------------------------------------- vesense commented on issue #45: ROCKETMQ-82: RocketMQ-Flink Integration URL: https://github.com/apache/rocketmq-externals/pull/45#issuecomment-371717499 Added unit tests. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Add the RocketMQ plugin for the Apache Flink > -------------------------------------------- > > Key: ROCKETMQ-82 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-82 > Project: Apache RocketMQ > Issue Type: Wish > Components: rocketmq-externals > Reporter: vongosling > Assignee: Xin Wang > Priority: Minor > > A few basic data sources and sinks are built into Flink and are always > available. The [predefined data > sources|https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.html#data-sources] > include reading from files, directories, and sockets, and ingesting data > from collections and iterators. The [predefined data > sinks|https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/datastream_api.html#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] -- This message was sent by Atlassian JIRA (v7.6.3#76005)