Streaming using Flink to connect Kafka and Elasticsearch - View it on GitHub