flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Madhukar Thota <madhukar.th...@gmail.com>
Subject Kafka + confluent schema registry Avro parsing
Date Thu, 19 Nov 2015 08:51:39 GMT

I am very new to Avro. Currently I am using confluent Kafka version and I
am able to write an Avro message to Kafka by storing schema in schema
registry. Now I need to consume those messages using Flink Kafka Consumer
and having a hard time to deserialize the messages.

I am looking for an example on how to deserialize Avro message where schema
is stored in schema registry.

Any help is appreciated. Thanks in Advance.


View raw message