This is a sample Java application reading data from Kafka and pass it to Flink, and then finally, it goes to Elasticsearch.
guuuuo / kafka-flink-es Goto Github PK
View Code? Open in Web Editor NEWThis project forked from liu-xiao-guo/kafka-flink-elasticsearch