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

e0bqpujr 于 2021-06-21 发布在 Storm

关注(0)|答案(1)|浏览(629)

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

Java testing apache-storm topology

来源：https://stackoverflow.com/questions/35766062/how-to-check-a-storm-topology-is-loaded-and-up-and-running-in-java

1条答案

按热度按时间

dgtucam11#

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

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

赞(0）回复(0）举报 2021-06-21

我来回答

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

1条答案

相关问题

热门标签

最新问答