我们有3台Kafka机器版本-0.10.0.2.6
我们要清除所有Kafka主题中的所有数据文件(完全清除所有数据)
此操作的cli应该是(应该从zoo服务器运行)
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
.
. .
因为我们临时将主题的保留时间更新为1秒(1000毫秒)
那怎么还以前的原版保留呢!
注意-log.retention.hours=168(来自ambari gui),这是原始值
那么,如何返回所有主题的原始值(168小时)?清除所有主题之后?
主题列表
/usr/hdp/2.6.0.3-8/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
_schemas
hrtfsa.polr.mdr.initial
hrtfsa.polr.pri.content_analysis
hrtfsa.polr.pri.decoded
hrtfsa.polr.pri.enriched.suspected_relation
hrtfsa.polr.pri.id_correlation
hrtfsa.polr.pri.processed
hrtfsa.polr.suspected_relations
hrtfsa.monitoring.heartbeat
我发现这个(https://gist.github.com/dmitz/47e230b35d84df900c2d57370f4e85b2 )
清除主题:
kafka-topics --zookeeper <zookeeper_address> --alter --topic <topic_name> --config retention.ms=1000
返回保留的原始值:
kafka-topics --zookeeper <zookeeper_address> --alter --topic <topic_name> --delete-config retention.ms
版本0.10.0.2.6是否正确?
暂无答案!
目前还没有任何答案,快来回答吧!