如何通过 java 代码获取风暴拓扑状态？

【问题标题】：How can I get storm topology status via java code?如何通过 java 代码获取风暴拓扑状态？
【发布时间】：2013-12-02 23:49:36
【问题描述】：

我对风暴很陌生。我想管理他们需要告知其状态的两个拓扑。我是否无法理解拓扑状态已停用或不在 java 类中提交另一个？

【问题讨论】：

标签： status apache-storm topology

【解决方案1】：

您可以使用 Thrift API：

  NimbusClient nimbusClient = NimbusClient.getConfiguredClient(Utils.readDefaultConfig())
  nimbusClient.getClient().getClusterInfo().get_topologies()
  …

见https://github.com/nathanmarz/storm/blob/master/storm-core/src/storm.thrift

【讨论】：

谢谢，但是由于它使用 NimbusClient，我可以在没有任何集群的本地系统中测试它吗？
@saharshokouhi 先试试吧！