Hi Fabian We are already using Flink to read json messages from kafka and index into elasticsearch. Now we have a requirement to read protobuf messages from kafka. I am new to protobuf and looking for help on how to deserialize protobuf using flink from kafka consumer.
-Madhu On Wed, Mar 9, 2016 at 5:27 AM, Fabian Hueske <fhue...@gmail.com> wrote: > 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? >> > >
