如何删除kafka中被标记的topic
时间: 2023-10-08 19:06:26 浏览: 238
Kafka源码系列教程之删除topic
要删除 Kafka 中被标记的 topic,需要执行以下步骤:
1. 确认 Kafka 版本是否支持删除 topic 功能。Kafka 0.11.0.0 版本之后支持删除 topic,如果你的版本低于此,需要升级 Kafka 版本。
2. 在 Kafka 集群中找到一个 broker,运行以下命令:
```
bin/kafka-topics.sh --delete --zookeeper <zookeeper-host>:<zookeeper-port> --topic <topic-name>
```
其中,`<zookeeper-host>` 是 ZooKeeper 的主机名或 IP 地址,`<zookeeper-port>` 是 ZooKeeper 的端口号,默认为 2181。`<topic-name>` 是要删除的 topic 名称。
3. 确认 topic 是否已被删除。你可以使用以下命令列出 Kafka 集群中所有的 topic:
```
bin/kafka-topics.sh --list --zookeeper <zookeeper-host>:<zookeeper-port>
```
如果你无法再看到要删除的 topic,说明已经成功删除了。
阅读全文