本地能正常接收kafka的数据，但是集群上报错

来源：6-10 -Storm集群部署之Storm集群部署及启动

慕仔0107391

2018-09-21

老师您好，
打包到集群上执行发现kafkaSpout有报错

KafkaSpout	KAFKA	Unable to get offset lags for kafka. Reason: java.lang.IllegalArgumentException: zk-node '/hello_topic/0aaeb195-d649-4623-82c6-f09759f1011e' dose not exists. at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOldConsumerOffsetsFromZk(KafkaOffsetLagUtil.java:387) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOffsetLags(KafkaOffsetLagUtil.java:268) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.main(KafkaOffsetLagUtil.java:124)

使用 zkCli.sh 查看过，根目录下是没有 /hello_topic 的

写回答

1回答