storm和kafka整合本地不报错，提交集群报错，请Michael__PK老师帮忙分析下如何解决？

Question

KafkaSpout KAFKA Unable to get offset lags for kafka. Reason: java.lang.IllegalArgumentException: zk-node ‘/test_topic/5d67c2c9-1610-41c7-83c2-f2ffadf5e620’ dose not exists. at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOldConsumerOffsetsFromZk(KafkaOffsetLagUtil.java:404) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.getOffsetLags(KafkaOffsetLagUtil.java:270) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.main(KafkaOffsetLagUtil.java:126)

Answer 1

提问者 mybatis 2018-10-22 10:50:11

在本地测的时候用的是线上的kafka和zookeeper

• Michael_PK #1

  换个topic，不然容易出现offset错乱

Answer 2

提问者 mybatis 2018-10-22 10:23:44

Michael_PK 老师，是不是有别方面的原因？

Answer 3

提问者 mybatis 2018-10-22 10:19:39

新建了一个topic，还是报这个错误

• Michael_PK #1

  本地和集群的分开topic，测试，建议是这样的

Answer 4

Michael_PK 2018-10-21 23:27:11

你集群中换个topic，肯定是用的那个topic被污染了