如何检查实际的storm拓扑是否已由storm加载并运行,以便在其上进行测试。因为执行集成测试需要等到拓扑运行之后才能开始测试逻辑。在本地群集上。
dgtucam11#
您可以使用storm命令行接口或直接使用java客户机api。例如:
NimbusClient nimbusClient = new NimbusClient(conf, nimbusHost, nimbusPort, 30000); List<TopologySummary> topologies = nimbusClient.getClient().getClusterInfo().get_topologies();
1条答案
按热度按时间dgtucam11#
您可以使用storm命令行接口或直接使用java客户机api。例如: