在kafka中,如果启用了日志压缩,它将只存储最近的键值。如果我们尝试回复这些邮件,它会重播最新的邮件吗?Kafka的回答到底是怎么回事?
rkue9o1l1#
对。删除先前的重复键的偏移量,并保留最新的键偏移量。使用者跳过代理偏移量中的间隙以读取所有可用消息此外,日志压缩是按计划进行的,因此您可能会在一段时间内看到分区中的同一个键,这取决于在代理/主题上定义的属性。
1条答案
按热度按时间rkue9o1l1#
对。删除先前的重复键的偏移量,并保留最新的键偏移量。使用者跳过代理偏移量中的间隙以读取所有可用消息
此外,日志压缩是按计划进行的,因此您可能会在一段时间内看到分区中的同一个键,这取决于在代理/主题上定义的属性。