NimbusLeaderNotFoundException в Apache Storm UI

Question

Я пытаюсь запустить интерфейс Storm для потокового приложения, однако постоянно получаю эту ошибку:

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)

Я запускал шторм локально, используя сценарий шторма для запуска nimbus, отправки jar и пользовательского интерфейса опроса. В чем может быть причина?

Вот код с настройкой соединения:

 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())

Answer 1

Когда вы отправляете в реальный кластер, используя storm jar, вы не должны использовать LocalCluster. Вместо этого используйте класс StormSubmitter.

Ошибка, которую вы получаете, говорит о том, что он не может найти Nimbus в localhost. Вы уверены, что Nimbus работает на машине, с которой вы работаете storm jar? Если это так, пожалуйста, опубликуйте команды, которые вы выполняете, и, возможно, также проверьте журнал Nimbus.