Re: Avro serialization and deserialization to Kafka in Scala

2019-02-07 Thread Kostas Kloudas
Hi Wouter, I think Gordon or Igal are the best to answer this question. Cheers, Kostas On Thu, Feb 7, 2019 at 11:04 AM Wouter Zorgdrager wrote: > Hello all, > > > I saw the recent updates in Flink related to supporting Avro schema > evolution in state. I'm curious how Flink handles this intern

Avro serialization and deserialization to Kafka in Scala

2019-02-07 Thread Wouter Zorgdrager
Hello all, I saw the recent updates in Flink related to supporting Avro schema evolution in state. I'm curious how Flink handles this internally for Scala case classes. I'm working on custom (de-)serialization schema's to write and read from Kafka. However, I'm currently stuck because of the f