Hello Team,

As our schema evolves due to business logics. We want to use expendable
schema like Avro as default serializer and deserializer for flink program
and states.

My doubt is, We are using Scala API in our flink program, But Avro default
supports Java POJO. So how we can use this in our scala APi should we have
to use serializer like Avro4s ? Or we can use default Avro in our Scala
flink app than what will be the steps ?

Please guide.

-- 
Thanks Regards

SHASHANK AGARWAL
 ---  Trying to mobilize the things....




‌

Reply via email to