Cluster Partition Rebalancer For Kafka is a tool that runs in the background on Kafka brokers and lets them move partitions across brokers to maintain a good balance of partitions per broker.
[This is at a Proof of Concept stage. You might have to change some utility code. Example: How to fetch all broker and zookeeper machines on your cluster]
Run the jar like this (preferably as a service so that it is restarted upon exit):
```
rm -f partitions-to-move.json*
On Windows:
java -cp “partitionRebalancerForKafka-1.0-SNAPSHOT.jar;*” BrokerLoadWatcher
On Linux:
java -cp “partitionRebalancerForKafka-1.0-SNAPSHOT.jar:*” BrokerLoadWatcher
## License
[](https://github.com/Microsoft/SparkCLR/blob/master/LICENSE.txt)
Cluster Partition Rebalancer For Kafka is licensed under the MIT license. See [LICENCE.txt](/mirrors/Cluster-Partition-Rebalancer-For-Kafka/tree/master/LICENCE.txt) file for full license information.
Cluster Partition Rebalancer For Kafka
Cluster Partition Rebalancer For Kafka is a tool that runs in the background on Kafka brokers and lets them move partitions across brokers to maintain a good balance of partitions per broker.[This is at a Proof of Concept stage. You might have to change some utility code. Example: How to fetch all broker and zookeeper machines on your cluster]
Read more at: https://onedrive.live.com/redir?resid=98916D951A1A5BFB!2128&authkey=!ALpNOGFF80csKdo&ithint=file%2cpdf
Usage
Clone the repository locally Git clone
Change directory to your repo
Build and package the project
Run the jar like this (preferably as a service so that it is restarted upon exit): ``` rm -f partitions-to-move.json*
On Windows: java -cp “partitionRebalancerForKafka-1.0-SNAPSHOT.jar;*” BrokerLoadWatcher
On Linux: java -cp “partitionRebalancerForKafka-1.0-SNAPSHOT.jar:*” BrokerLoadWatcher