java - 如何从 Java 代码启动 Apache Storm UI？

Question

我使用 Storm 开发了一个流处理项目。我创建了一个拓扑并通过执行项目的 Main 类来运行它。

在 Storm 教程中，我看到了一个从 8080 端口访问的 UI，它显示了 Spout 和 Bolt 的详细信息。但是，我找不到启动用户界面的方法。我怎样才能做到这一点？

<小时/>

pom.xml 文件:

<dependency>
    <groupId>org.apache.storm</groupId>
    <artifactId>storm-core</artifactId>
    <version>1.2.2</version>
    <scope>compile</scope>
</dependency>

主类:

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("TwitchSpout", new TwitchSpout());
builder.setBolt("MessageBolt", new MessageBolt()).shuffleGrouping("TwitchSpout");

Config conf = new Config();
conf.setDebug(false);

new LocalCluster().submitTopology("MyFirstTopo", conf, builder.createTopology());

我想要启动的用户界面:

Answer 1

您正在将拓扑作为本地集群运行，这仅用于测试。您应该在真实的集群上运行它(请参阅 https://storm.apache.org/releases/2.0.0-SNAPSHOT/Setting-up-a-Storm-cluster.html )。

设置完成后，您可以使用命令storm ui启动Storm UI。使用storm.sh storm/bin 中的脚本。目前无法在 LocalCluster 中启动 Storm UI。