flink avro schema 升级变动，job如何平滑过渡

[Peihui He]

Hi, all

请教大家有没有遇到这样的情况，flink 使用avro
消费kafka中数据，后来在schema结构中加入新的字段。在灰度过程中会混杂着新老数据，这样的flink 消费程序就会挂掉。

大家一般是怎么处理的呢

Best Wishes.