java - 如何检查 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();