一個線上的簡單的wordcount導致出錯:
Unable to get offset lags for kafka. Reason: java.lang.NullPointerException at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.
getOffsetLags(KafkaOffsetLagUtil.java:272) at org.apache.storm.kafka.monitor.KafkaOffsetLagUtil.main(KafkaOffsetLagUtil.java:124)
TopologyBuilder topologyBuilder = new TopologyBuilder();
SpoutConfig spoutConfig = new SpoutConfig(
new ZkHosts("kong1:2181,kong2:2181,kong3:2181,kong4:2181,kong5:2181"),
"wordCount",
"/wordCount",
"wordCount");
spoutConfig.startOffsetTime = kafka.api.OffsetRequest.LatestTime();
topologyBuilder.setSpout("KafkaSpout",new KafkaSpout(spoutConfig),2);
topologyBuilder.setBolt("bolt1",new MySplitBolt(),4).shuffleGrouping("KafkaSpout");
topologyBuilder.setBolt("bolt2",new MyWordCountAndPrintBolt(),2).shuffleGrouping("bolt1");
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/44148.html
標籤：Spark
下一篇：請教下swarm的調度策略問題