[ https://issues.apache.org/jira/browse/FLINK-4837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581175#comment-15581175 ]
ASF GitHub Bot commented on FLINK-4837: --------------------------------------- GitHub user sbcd90 opened a pull request: https://github.com/apache/flink/pull/2644 [FLINK-4837] flink-streaming-akka source connector This PR is created to propose the idea of having a `flink-streaming-akka source connector`. The source connector can be used to receive messages from an Akka feeder or publisher actor & these messages can then be processed using flink streaming. The source connector has the following features. - It can supports several different message formats like iterable data, bytes array & data with timestamp. - It can send back acknowledgements to the feeder actor. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sbcd90/flink flink-akka Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2644.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2644 ---- commit c05274058a2a7f152e668ea464e257ca9dc5aac0 Author: Subhobrata Dey <sbc...@gmail.com> Date: 2016-10-15T22:09:56Z [FLINK-4837] flink-streaming-akka source connector ---- > flink-streaming-akka source connector > ------------------------------------- > > Key: FLINK-4837 > URL: https://issues.apache.org/jira/browse/FLINK-4837 > Project: Flink > Issue Type: New Feature > Components: Streaming Connectors > Reporter: Subhobrata Dey > > Hello, > This issue is created to propose the idea of having a flink-streaming-akka > source connector. > The source connector can be used to receive messages from an Akka feeder or > publisher actor & these messages can then be processed using flink streaming. > The source connector has the following features. > 1. It can supports several different message formats like iterable data, > bytes array & data with timestamp. > 2. It can send back acknowledgements to the feeder actor. > Thanks & regards, > Subhobrata -- This message was sent by Atlassian JIRA (v6.3.4#6332)