Kafka提供了两种主要的日志清理策略：日志删除（Log Deletion）和日志压缩（Log Compaction），以帮助管理磁盘空间并保持数据的高效存储和传输。以下是具体的清理方法：
log.cleanup.policy=delete 来启用。log.cleanup.policy=compact 来启用。一个简单的Kafka配置文件示例，演示了如何配置日志保留期和数据清理策略：
# Kafka Broker 配置文件
############################# Server Basics #############################
# Kafka 服务器监听的地址和端口
listeners=PLAINTEXT://localhost:9092
# Kafka 数据目录
log.dirs=/kafka/logs
# 日志保留策略
log.retention.hours=168 # 保留7天的消息数据
# 数据清理策略
log.cleanup.policy=delete # 使用删除策略进行数据清理
# 数据保留大小限制
log.retention.bytes=-1 # 不限制消息数据的大小
通过合理配置日志保留期和数据清理策略，可以有效地管理磁盘空间，同时确保数据的高可用性和可访问性。
