[BAHIR-73] [bahir-flink] flink-streaming-akka source connector

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: Flink-1.0
• Fix Version/s: Flink-1.1.0
• Component/s: Flink Streaming Connectors
• Assignee: Subhobrata Dey
• Reporter: Subhobrata Dey
• Created: 25/Oct/16 18:43
• Updated: 23/May/17 18:56
• Resolved: 03/Mar/17 03:55

Description

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

Issue Links

• links to: GitHub Pull Request #8