I'm very new at storm. I want to manage two topology which they need to inform about their status. Is it impossible that I understand status of topology is deactivated or not to submit another one in java class?
You can use the Thrift API:
NimbusClient nimbusClient = NimbusClient.getConfiguredClient(Utils.readDefaultConfig())
nimbusClient.getClient().getClusterInfo().get_topologies()
…
See https://github.com/nathanmarz/storm/blob/master/storm-core/src/storm.thrift
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With