前言
Kafka将消息存储在磁盘中，为了控制磁盘占用空间。kafka中每个分区副本都对应一个Log，而Log对应多个日志分段，这样有利日志清理操作。Kafka提供两种日志清理策略：
- 日志删除（Log retention）：按一定的保留的策略直接删除不符条件的日志分段；
- 日志压缩（Log compation）：针对每个消息的Key对行整合，对于相同Key的不同value值，只保留最后一个版本；
Broker端参数log.cleanup.policy来设置日志清理策略，此参数默认为delete，也可以设置成compact，还可以设置成delete,compact；
日志删除