[
https://issues.apache.org/jira/browse/ROCKETMQ-82?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16373859#comment-16373859
]
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-367898289
Will add more unit tests later.
----------------------------------------------------------------
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: Longda Feng
> Assignee: Xin Wang
> Priority: Minor
> Labels: gsoc2018
>
> 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)
