You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/10/25 18:43:59 UTC

[jira] [Created] (BAHIR-73) [bahir-flink] flink-streaming-akka source connector

Subhobrata Dey created BAHIR-73:
-----------------------------------

             Summary: [bahir-flink] flink-streaming-akka source connector
                 Key: BAHIR-73
                 URL: https://issues.apache.org/jira/browse/BAHIR-73
             Project: Bahir
          Issue Type: New Feature
          Components: Flink Streaming Connectors
            Reporter: Subhobrata Dey
             Fix For: Flink-0.1


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)