我们都知道,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

在这里插入图片描述

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐