1

我有一个通过设置 cleanup.policy=compact 启用压缩的 Kafka 主题。我的 segment.bytes 属性设置为稍大的值 (100Mb),以便我的经纪人表现良好。

如果我有一个将主题用作 GlobalKTable 的 Kafka 流应用程序,并且主题中的单个分区键有多个记录,那么该应用程序会在 GlobalKTable 中仅接收 1 条记录,还是在压缩开始之前将有两条记录?

4

1 回答 1

1

GlobalKTable 中只有 1 条记录,因为 Tables 默认是 RocksDB 状态存储,它是键值存储。因此,即使主题有多个作为键,表也只有一个。

于 2020-08-26T16:59:53.753 回答