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 的文章

關鍵字: 如何 运行 本地