storm如何本地運行（Local）？

• 代碼：

conf.setMaxTaskParallelism(1);

LocalCluster cluster = new LocalCluster();

cluster.submitTopology("srslog", conf, builder.createTopology());

Thread.sleep(180000);

cluster.killTopology("storm-mobile1");

cluster.shutdown();

• 運行報錯：

storm java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce$class

原因分析：

The collection API is different between Scala 2.10 and 2.11

Scala 2.10 - kafka_2.10-0.10.2.1

Scala 2.12 - kafka_2.12-0.10.2.1

org.apache.kafka

kafka_2.10

0.10.2.1

org.scala-lang

scala-library

2.10.6

測試ok 從2.11 降低到2.10

說明：具體kafka那個版本 是看出錯日誌 根據我是根據官方文檔 下載的

閱讀更多 JiaGouS 的文章

關鍵字: 本地 技術 編程語言