鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

Storm+Kafka某个测试用例测试完成后未自动删除相应产生的topic的解决方法

问题现象描述

Storm+Kafka某个测试用例测试完成后未自动删除相应产生的topic。

关键过程、根本原因分析

结论、解决方案及效果

删除该用例产生的topic。

storm list
storm kill wordcount
zklist=DataNode1:24002,DataNode2:24002,DataNode3:24002
kafka-topics.sh --zookeeper $zklist:24002/kafka --delete --topic testTopic