You can run the preferred replica leader election tool after the restarts (https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools)
- cluster reboot and leader selection Yu, Libo
- Re: cluster reboot and leader selection Joel Koshy
- RE: cluster reboot and leader selection Yu, Libo
- Re: cluster reboot and leader selection Joel Koshy