Flink stream processing integrated with Kafka - View it on GitHub