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. Cluster Partition Rebalancer For Kafka
[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]
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
Cluster Partition Rebalancer For Kafka is licensed under the MIT license. See LICENCE.txt file for full license information.