Hi all,


    最近在测试Upsert Kafka,在验证的过程中,发现Validation的时候要求format的changelog-mode 
必须是insert-only的,请问这是什么原因呢。

    如果不是的话,请直接指正我,谢谢。





Flink version 1.12.1

回复