Hello, I need to support Flink application accepting avro binary events with different schemas over flink kafka source. Need to use custom schema registry to fetch schema at runtime and decode the incoming event.
Will use Avro Generic Record to decode incoming event with different avro schemas. Gone through the page - Flink Serialization Tuning Vol. 1: Choosing your Serializer - if you can | Apache Flink<https://flink.apache.org/2020/04/15/flink-serialization-tuning-vol.-1-choosing-your-serializer-if-you-can/#avro-generic>. Can you please tell as at compile/job graph time schema is not available then it will use Kryo as serialzer? Also anything can be done here to improve it as for Kryo perf. is impacted? Rgds, Kamal
