如何检查 Storm 拓扑是否已加载并在 Java 中启动并运行

Question

如何检查 Storm 是否已加载并运行实际的 Storm 拓扑，以便在其上进行测试。因为执行集成测试需要等到拓扑运行后才能开始测试逻辑。在本地集群上。

Answer 1

您可以使用storm command line interface 或直接使用Java 客户端API。例如：

NimbusClient nimbusClient = new NimbusClient(conf, nimbusHost, nimbusPort, 30000);
List<TopologySummary> topologies = nimbusClient.getClient().getClusterInfo().get_topologies();