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

方法一

修改kafka配置文件

log.retention.hours=24
log.cleanup.policy=delete

方法二

使用kafka脚本

./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

相关文章

发表新评论