5.10. 删除主题
kafka-topics.sh 工具可用于管理主题。kafka-topics.sh 是 AMQ Streams 发布的一部分,可以在 bin 目录中找到。
先决条件
- AMQ Streams 集群已安装并运行
-
主题
mytopic存在
删除主题
使用
kafka-topics.sh实用程序删除主题。-
在
--bootstrap-server选项中 Kafka 代理的主机和端口。 -
使用
--delete选项指定应删除现有主题。 主题名称必须在
--topic选项中指定。bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --delete --topic <TopicName>
bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --delete --topic <TopicName>Copy to Clipboard Copied! Toggle word wrap Toggle overflow 创建名为 的主题的命令示例
mytopicbin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopic
bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic mytopicCopy to Clipboard Copied! Toggle word wrap Toggle overflow
-
在
使用
kafka-topics.sh验证主题已被删除。bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --list
bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --listCopy to Clipboard Copied! Toggle word wrap Toggle overflow 列出所有主题的命令示例
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
bin/kafka-topics.sh --bootstrap-server localhost:9092 --listCopy to Clipboard Copied! Toggle word wrap Toggle overflow
其它资源
- 有关创建主题的详情请参考 第 5.7 节 “创建主题”。