A demo application which receives the real time message from kafka and do some data processing job on them and sink them into ElasticSearch finally.
Flink ElasticSearch Connector supports ElasticSearch only up to version 5.x, but I use 6.2.x. I implemented a custom sinker by using the official ElasticSearch Java API.
After/ During the data are written into ElasticSearch, they can be visualized in Kibana in real time.
