[ https://issues.apache.org/jira/browse/BAHIR-73?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Luciano Resende reassigned BAHIR-73: ------------------------------------ Assignee: Subhobrata Dey > [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 > Assignee: 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.15#6346)