jstorm、storm 常见问题

1，找不到brokerZkPath

org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode= NoNode for /brokers/topics/task_data_v2/partitions

①、看下zk有没有这个目录，如果zk有这个目录，出现这种情况可以先尝试删除一下kafka的和storm的缓存试一下

②、如果你kafka指定了zk目录，在配置kafkaSpout时注意下面代码

BrokerHosts brokerHosts = new ZkHosts("wycoldb01:2181,wycoldb02:2181,wycoldb05:2181", "/kafka/brokers");
SpoutConfig spoutConf = new SpoutConfig(brokerHosts, "test", "/kafkastorm", "word");

ZkHosts有两个构造方法，如果你指定了kafka路径不在zk的根目录，要使用两个参数的构造方法指定路径

附：

2，通讯异常

java.lang.RuntimeException: java.nio.channels.ClosedChannelException
检查jstorm节点间是否能正常通讯，检查/etc/hosts 是否配置错误，检查kafka监听的ip
kafka相关配置：
listeners=PLAINTEXT://192.168.31.35:9092
advertised.listeners=PLAINTEXT://192.168.31.35:9092

欢迎大家加入QQ群：629869847 交流学习

待续