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

gcxthw6b 于 2021-06-24 发布在 Storm

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

我对风暴很陌生。我想管理两个拓扑，他们需要告知他们的状态。我不可能了解拓扑的状态是停用的还是不在java类中提交另一个拓扑？

apache-storm topology status

来源：https://stackoverflow.com/questions/20071327/how-can-i-get-storm-topology-status-via-java-code

1条答案

按热度按时间

fae0ux8s1#

您可以使用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

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

我来回答

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

1条答案

相关问题

热门标签

最新问答