Running a simple streaming application on top of Apache Flink with using Apache Kafka as Source and Sink
This post describes how to utilize Apache Kafka as Source as well as Sink of realtime streaming application that run on top of Apache Flink.
The previous post describes how to launch Apache Flink locally, and use Socket to put events into Flink cluster and process in it.
Please refer to it to get