我正在尝试为流媒体应用程序启动storm ui，但经常出现以下错误：
org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds?
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:250)
at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:179)
at org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:138)
at org.apache.storm.daemon.ui.resources.StormApiResource.getClusterConfiguration(StormApiResource.java:116)我已经在本地启动了storm，使用storm脚本启动nimbus、提交jar和轮询ui。原因可能是什么？
以下是连接设置的代码：
val cluster = new LocalCluster()
val bootstrapServers = "localhost:9092"
val spoutConfig = KafkaTridentSpoutConfig.builder(bootstrapServers, "tweets")
.setProp(props)
.setFirstPollOffsetStrategy(FirstPollOffsetStrategy.LATEST)
.build()
val config = new Config()
cluster.submitTopology("kafkaTest", config, tridentTopology.build())
1条答案
按热度按时间py49o6xq1#
当您使用
storm jar，不应使用localcluster。而是使用StormSubmitter班级。你得到的错误是在localhost上找不到nimbus。你确定nimbus在你运行的机器上运行吗
storm jar从哪里来的？如果是这样，请发布您正在运行的命令，也可以查看nimbus日志。