我们有 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 小时)?清除所有主题后?
您运行相同的命令,但将保留时间设置为 168 小时(以毫秒为单位)。