flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Madhukar Thota <madhukar.th...@gmail.com>
Subject Re: protobuf messages from Kafka to elasticsearch using flink
Date Wed, 09 Mar 2016 20:36:47 GMT
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 <fhueske@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.thota@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?
>>
>
>

Mime
View raw message