清除 kafka 主题后如何恢复原始日志保留

清除 kafka 主题后如何恢复原始日志保留

我们有 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 小时(以毫秒为单位)。

相关内容