hi i am trying write a script for safe rolling restart of kafka_2.9.2-0.8.1.1 cluster , high level workflow is
for each broker do 1. move partition replica leadership from current_broker to others 2. broker restart 3. restore leadership borker now i have found a script to do 1. https://gist.github.com/miguno/87d5b2411e3f93e80866 i am not sure how to do 3.
