apache-flink - upsert kafka 是否应该与压缩主题一起使用
问题描述
我正在使用普通(未压缩)主题,它看起来工作正常,我可以使用同一密钥的所有消息(来自 upsert-kafka 接收器)。
但是在我看来 upsert-kafka 也可以与压缩主题一起使用,也就是说,对于相同的键,它们可以被 Kafka 压缩,这样我就可以为相同的键消耗更少的消息?
解决方案
推荐阅读
- nginx - 为什么 Nginx 0 秒延迟和 1 秒延迟有很大不同?以及如何计算?
- python - 用于 Ajax 的 Django csrf 令牌
- html - 引导偏移不起作用
- python - 每次我尝试运行应用程序时都会出现“RuntimeError:生成器引发 StopIteration”
- python-3.x - 如何修复错误 urllib.error.HTTPError:HTTP 错误 400:错误请求?
- python - 用于 MT 的 Jasmin HttpConnector
- php - 使用循环从PHP中的数据库中获取数据
- c# - 基于接口对象类型的方法偏差
- python - 当只有两个键可用时,Python如何从字典中获取键值对范围
- ios - UIPickerView numberOfRowsInComponent 运行三次