进入kafka配置文件,修改 server.properties 文件。
1 log.retention.hours=1 # 超过1个小时就清理数据
2 log.segment.bytes=5000 # 数据量超过5000byte就清理数据
3 log.cleanup.interval.mins=100 # 指定日志每隔多久检查看是否可以被删除,默认1分钟
4 log.retention.check.interval.ms=300 # 文件大小检查的周期时间,是否触发 log.cleanup.policy中设置的策略