Kafka删除策略是否适用于活跃日志段？实测疑问求证

引用Emil Koutanov所著《Effective Kafka》内容：删除策略以日志段为粒度，副本内的后台进程仅检查非活跃日志段是否可删除；仅生产者写入操作可作用于活跃段，删除、压缩等操作仅针对非活跃段。

你的测试现象和作者描述并不冲突，核心原因是闲置的活跃段会被Kafka自动转为非活跃段，再执行删除逻辑，具体拆解如下：

• 活跃段的动态状态：Kafka的活跃段并非永久固定，它的定义是「当前正在接收生产者写入的日志段」。一旦该段长时间没有新写入（比如你测试中停止生产后），它就不再承担写入功能，后台清理线程会将其标记为非活跃段。
• 作者描述的适用场景：《Effective Kafka》的说法针对的是有持续写入的活跃段——此时删除/压缩操作确实不会触碰正在被写入的活跃段，避免影响生产者写入。但当活跃段变为闲置状态后，就不再受这个限制。
• 你的测试场景逻辑：生产2-3条消息后停止写入，该活跃段进入闲置状态；30秒后满足retention.ms条件，后台检查线程（因log.retention.check.interval.ms=1秒会高频触发）先将其转为非活跃段，随后执行删除；之后Kafka自动新建一个空的活跃段，等待后续写入。

如果想验证这个逻辑，可以在retention.ms到期前继续向该topic生产消息，此时活跃段会保持活跃状态，不会被删除，完全符合作者的描述。

内容的提问来源于stack exchange，提问作者Ivan Petrov