我们有 3 台 kafka 机器版本 - 0.10.0.2.6
我们要清除所有 kafka 主题中的所有数据文件(彻底清除所有数据)
此操作的 CLI 应该是(应该从动物园服务器运行)
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic1 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic2 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic3 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic Topic4 --config retention.ms=1000
由于我们暂时将主题的保留时间更新为一秒(1000 毫秒)
那如何恢复之前的原有保留!
注意 - log.retention.hours = 168(来自 ambari GUI)这是原始值
那么,清除所有主题后,如何将所有主题恢复到原始值(168 小时)?
答案1
您运行相同的命令,但将保留时间设置为 168 小时(以毫秒为单位)。