Apache Storm UI中的NimbusLeaderNotFoundException

问题描述 投票:0回答:1

我正在尝试为流应用程序启动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)

我已经使用风暴脚本在本地启动了风暴,以启动雨云,提交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())
scala user-interface apache-kafka apache-storm
1个回答
0
投票
© www.soinside.com 2019 - 2024. All rights reserved.