apache storm - Topology spouts lag error -
i getting strange error while after storm topology created. in "topology spouts lag error" part of storm-ui. says:
unable offset lags kafka. reason: java.lang.nullpointerexception @ org.apache.storm.kafka.monitor.kafkaoffsetlagutil.getoffsetlags(kafkaoffsetlagutil.java:269) @ org.apache.storm.kafka.monitor.kafkaoffsetlagutil.main(kafkaoffsetlagutil.java:127)
there topic inside kafka , check topic /bin/kafka-console-consumer.sh
any idea? thank you
Comments
Post a Comment