Hi. 当初的设计是基于kafka的compacted topic设计的，而compacted topic有自身的表达changelog的语法，例如：使用value 为 null 表示tombstone message。从这个角度出发的话，我们仅从kafka的角度去理解数据，而非从format的角度去解析数据。
这当然引入了一些问题，例如当利用upsert-kafka读取数据的时候需要维护一个state以记住读取的所有的key。 Best, Shengkai 刘首维 <liushou...@autohome.com.cn> 于2021年3月15日周一 上午11:48写道： > Hi all, > > > > 最近在测试Upsert Kafka，在验证的过程中，发现Validation的时候要求format的changelog-mode > 必须是insert-only的，请问这是什么原因呢。 > > 如果不是的话，请直接指正我，谢谢。 > > > > > > Flink version 1.12.1 >
