7.10. 删除主题
kafka-topics.sh 工具可用于管理主题。kafka-topics.sh 是 Apache Kafka 发行版本的 Streams 的一部分，可在 bin 目录中找到。
先决条件
- 每个主机上安装了 Apache Kafka 的流，且配置文件可用。
删除主题
使用
kafka-topics.sh工具删除主题。-
在
--bootstrap-server选项中的 Kafka 代理的主机和端口。 -
使用
--delete选项指定应删除现有主题。 主题名称必须在
--topic选项中指定。/opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_host>:<port> --delete --topic <topic_name>
创建名为
mytopic的主题的命令示例/opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopic
-
在
使用
kafka-topics.sh验证主题是否已删除。/opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_host>:<port> --list
列出所有主题的命令示例
/opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
