kafka修改topic中的消息保留时间

警告
本文最后更新于 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
51303-tqyz0z8jibb.png

38008-tno15juopb.png
38008-tno15juopb.png

28708-hz6lb4dfj7n.png
28708-hz6lb4dfj7n.png

请我喝杯水
SoulChild 微信号 微信号
SoulChild 微信打赏 微信打赏
0%