修改kafka中某一主题的数据存留时间 - Go语言中文社区

修改kafka中某一主题的数据存留时间


我们都知道,kafka中默认消息的保留时间是7天,若想更改,需在配置文件
server.properties里更改选项:
log.retention.hours=168

但是有的时候我们需要对某一个主题的消息存留的时间进行变更,而不影响其他主题。且kafka集群不用重启

可以使用命令:
./kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name topicName --alter --add-config log.retention.hours=120
使得主题的留存时间保存为5天

如果报错的话,可以将时间单位更改成毫秒(3天):
./kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name topicName --alter --add-config retention.ms=259200000

修改完成之后可以使用–describe查看是否修改成功
./kafka-topics.sh --zookeeper localhost:2181 --topic topicName --describe
在这里插入图片描述

版权声明:本文来源CSDN,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/weixin_43255026/article/details/85333889
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2020-02-29 21:08:20
  • 阅读 ( 1406 )
  • 分类:

0 条评论

请先 登录 后评论

官方社群

GO教程

推荐文章

猜你喜欢