如何检查storm拓扑在java中是否已加载、启动和运行

e0bqpujr  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(664)

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

dgtucam1

dgtucam11#

您可以使用storm命令行接口或直接使用java客户机api。例如:

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

相关问题