警告
本文最后更新于 2021-12-09 21:13,文中内容可能已过时。
方法一
修改kafka配置文件
1
2
| log.retention.hours=24
log.cleanup.policy=delete
|
方法二
使用kafka脚本
1
| ./kafka-configs.sh --zookeeper localhost:2181 --alter --entity-name testlog --entity-type topics --add-config retention.ms=86400000
|
方法三
使用kafka-manager
51303-tqyz0z8jibb.png
38008-tno15juopb.png
28708-hz6lb4dfj7n.png