问题一 获取不到kafka
ERROR Node /broker/ids/270 does not exist
排查思路
zookeeper-client 进入zookeeper 查看路径下的情况
ls /broker/ids
查看kafka注册进来没有
如果是 [] 说明没注册进来
cdh查看ZooKeeper Root 看下路径 改成空的 即注册到默认地址
应该是注册到/“自己设置的路径”/broker/ids去了
问题二
[Thread-10-kafka-spout] ERROR b.s.util - Async loop died! Caused by: java.nio.channels.ClosedChannelException
版本不匹配 我的版本storm 0.95 kafka 2.12 版本差的太多了 这个版本官网都不支持了 无从查询 目前用0.8的kafka可以正常使用，查询较新的版本可以在官网查询匹配的kafka版本
选择版本 往下翻
点进去 往下翻
大概是说1.23 只支持1.0以上的kafka