1

我在我的 Mac 上使用默认服务器设置运行 Kafka 代理(版本 2.12)。我创建了一个日志压缩主题,具有以下配置 -

Configs: cleanup.policy=compact,segment.bytes=1073741824,delete.retention.ms=100,segment.ms=100

我生成了三个具有相同键/值的记录。5 分钟后(log.retention.check.interval.ms=300000),我从头开始阅读该主题。我在主题中看到以下三个记录。我期待 1 条记录。

key1:aaa
key1:aaa
key1:aaa

10 分钟后,我生成了一条具有相同键、不同值的记录 (key1:bbb)。然后在 5 分钟后,从头开始阅读主题导致以下两条记录。我期待 1 条记录 (key1:bbb)。

key1:aaa
key1:bbb

我需要设置任何其他主题配置吗?任何帮助或指示将不胜感激。

4

0 回答 0