各位好，请教一下 Flink 中我用的是upsert-kafka 为什么不支持 changelog?

在 Flink 1.53 版本之前，upsert-kafka 不支持 changelog。如果使用 upsert-kafka 将数据写入 Kafka,则只有当在 Kafka 中插入或更新记录时，Flink 才会将其视为新记录并将其写入。如果尝试将现有记录更改为不同的值并再次写入 Kafka,则 Flink 将不会将其视为新记录，而是会将其视为更新记录。

从 Flink 1.53 版本开始，upsert-kafka 支持 changelog。如果使用 upsert-kafka 将数据写入 Kafka,则无论您是在插入、更新还是删除记录时，Flink 都会将其视为新记录并将其写入。upsert-kafka 更适合处理具有复杂键和时间戳的实时数据流。