Kafka日志清理在Linux系统上可以通过配置文件server.properties
中的参数来实现。以下是一些常用的日志清理策略:
log.retention.hours=168
log.retention.bytes=1073741824
log.segment.bytes=1073741824
log.segment.bytes
的大小,Kafka也会创建一个新的日志段。例如,设置为1表示每小时滚动一次日志。log.roll.hours=1
delete
(默认)和compact
。delete
策略会删除过期的日志,而compact
策略会对日志进行压缩,保留每个键的最新值。log.cleanup.policy=delete
log.cleanup.interval.ms=300000
要修改这些参数,请编辑Kafka安装目录下的config/server.properties
文件,然后重启Kafka服务以使更改生效。
sudo systemctl restart kafka
请注意,根据您的需求和系统资源,您可能需要调整这些参数以获得最佳性能。在生产环境中,请确保充分测试这些设置,以确保它们满足您的需求。