Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

How can I get storm topology status via java code?

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?

like image 426
sahar shokouhi Avatar asked Apr 16 '26 19:04

sahar shokouhi


1 Answers

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

like image 147
schiavuzzi Avatar answered Apr 23 '26 07:04

schiavuzzi



Donate For Us

If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!