apache-kafka - 端到端程序以删除 kafka 主题

Question

我们有带 HDP 的 ambari 集群version 2.6.4，而 kafka 版本0.10.0.2.6（供应商-hortonworks，操作系统-redhat 7.2版本）

我们有 3 个 kafka 代理，所有主题分区都在/var/kafka/kafka_data文件夹下

卡夫卡经纪人 ID 是：

./zookeeper-shell.sh zookeper01:2181 <<< "ls /brokers/ids"
Connecting to zookeper01:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[103, 102, 101]

我们决定在 kafka 集群工作超过 2 年后的这个阶段从所有 kafka 代理中删除所有主题

来自 kafka 机器的主题示例

[root@kafka01 ~]# ./kafka-topics.sh --zookeeper zookeper01:2181 --list
__consumer_offsets
_schemas
ambari_kafka_service_check
mk.term.control.ova
mk.term.control.ovb
mk.term.control.ovc
mk.term.control.ovc
mk.sum.control.ova
mk.sum.control.ovb
mk.sum.control.ovc
mk.sum.control.ovc
mk.sum.control.ovd
mk.sum.control.ove
mk.sum.control.ovf
mk.sum.control.ovg
mk.sum.control.ova
mk.sum.control.ovb
.
.
.
.

此外，我通过在 Hortonworks 网站上的搜索了解到还需要从 zookeeper cli 中删除主题（https://community.hortonworks.com/answers/list.html）

不幸的是，我们没有找到完整的程序来逐步描述如何删除所有其他方面的主题（如在删除主题之前停止 kafka 代理等）

我很高兴获得适合 kafka 版本的完整程序 - 0.1.X

标签： apache-kafkaapache-zookeeper