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....
