Hi all,
最近在测试Upsert Kafka,在验证的过程中,发现Validation的时候要求format的changelog-mode
必须是insert-only的,请问这是什么原因呢。
如果不是的话,请直接指正我,谢谢。
Flink version 1.12.1
Hi all,
最近在测试Upsert Kafka,在验证的过程中,发现Validation的时候要求format的changelog-mode
必须是insert-only的,请问这是什么原因呢。
如果不是的话,请直接指正我,谢谢。
Flink version 1.12.1