Hi Raphael, I think you should use the Nimbus interface implementation: https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/generated/Nimbus.java Please find the rebalance() in this interface.
I have not fully explored this option though. You can obtain an instance of Nimbus interface implementation using NimbusClient.java https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/utils/NimbusClient.java I have used NimbusClient and Nimbus class to submit topology without using storm command. Please refer the following mail thread to find more details about using NimbusClient: https://groups.google.com/forum/#!searchin/storm-user/Can$20we$20submit$20the$20topology$20jar$20without$20using$20storm$20command/storm-user/5JjZQyviRqk/TGRCgciHKWwJ I think the trickiest part of your task will be the creation of RebalanceOptions instance: https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/generated/RebalanceOptions.java Regards, Richards Peter.
