即使没有启动记录的主题压缩,GlobalKTable 是否总是每个分区键只有 1 条记录?
Will GlobalKTable always have only 1 record per partition key even if topic compaction for records has not kicked in?
我有一个 Kafka 主题,它通过设置 cleanup.policy=compact 启用了压缩。
我的 segment.bytes 属性 设置为稍大的值 (100Mb),以便我的经纪人表现良好。
如果我有一个将主题用作 GlobalKTable 的 Kafka 流应用程序,并且主题中的单个分区键有多个记录,应用程序会在 GlobalKTable 中只收到 1 条记录还是会有两条记录直到压实开始了吗?
GlobalKTable 中只有 1 条记录,因为表默认是 RocksDB 状态存储,即 key-value 存储。因此,即使主题有多个键,table 也只有一个。
我有一个 Kafka 主题,它通过设置 cleanup.policy=compact 启用了压缩。 我的 segment.bytes 属性 设置为稍大的值 (100Mb),以便我的经纪人表现良好。
如果我有一个将主题用作 GlobalKTable 的 Kafka 流应用程序,并且主题中的单个分区键有多个记录,应用程序会在 GlobalKTable 中只收到 1 条记录还是会有两条记录直到压实开始了吗?
GlobalKTable 中只有 1 条记录,因为表默认是 RocksDB 状态存储,即 key-value 存储。因此,即使主题有多个键,table 也只有一个。