gpt4 book ai didi

status - 如何通过java代码获取 Storm 拓扑状态?

转载 作者:行者123 更新时间:2023-12-02 02:31:58 26 4
gpt4 key购买 nike

我对 Storm 还很陌生。我想管理两个拓扑,它们需要通知它们的状态。我是否不可能理解拓扑的状态已停用或不在 java 类中提交另一个拓扑?

最佳答案

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

关于status - 如何通过java代码获取 Storm 拓扑状态?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20071327/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com