Hi, I haven't used protobuf to serialize Kafka events but this blog post (+ the linked repository) shows how to write data from Flink into Elasticsearch:
--> https://www.elastic.co/blog/building-real-time-dashboard-applications-with-apache-flink-elasticsearch-and-kibana Hope this helps, Fabian 2016-03-09 2:52 GMT+01:00 Madhukar Thota <madhukar.th...@gmail.com>: > Friends, > > Can someone guide me or share an example on how to consume protobuf > message from kafka and index into Elasticsearch using flink? >
