You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Flavio Pompermaier <po...@okkam.it> on 2017/05/05 14:45:11 UTC
Flink + Kafka + avro example
Hi to all Flink users,
we've just published on our Okkam public repository an example of using
Flink 1.2.1 + Kafka 0.10 to exchange Avro objects[1].
We hope this could be helpful for new Flink users willing to play with
Flink streaming.
[1]
https://github.com/okkam-it/flink-examples/blob/master/src/main/java/org/okkam/flink/KafkaFlinkAvroParquet.java
Best,
Flavio
Re: Flink + Kafka + avro example
Posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org>.
Thanks a lot for sharing this Flavio!
On 5 May 2017 at 10:45:38 PM, Flavio Pompermaier (pompermaier@okkam.it) wrote:
Hi to all Flink users,
we've just published on our Okkam public repository an example of using Flink 1.2.1 + Kafka 0.10 to exchange Avro objects[1].
We hope this could be helpful for new Flink users willing to play with Flink streaming.
[1] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/org/okkam/flink/KafkaFlinkAvroParquet.java
Best,
Flavio