首页 > 解决方案 > upsert kafka 是否应该与压缩主题一起使用

问题描述

我正在https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/upsert-kafka/探索 flink upsert-kafka

我正在使用普通(未压缩)主题,它看起来工作正常,我可以使用同一密钥的所有消息(来自 upsert-kafka 接收器)。

但是在我看来 upsert-kafka 也可以与压缩主题一起使用,也就是说,对于相同的键,它们可以被 Kafka 压缩,这样我就可以为相同的键消耗更少的消息?

标签: apache-flink

解决方案


推荐阅读