Kafka - PartitionReassignment

Table of Contents

kafka-reassign-partitions

Why is this needed in the first place? Because the cluster needs to use all the new Brokers joining it (added by auto-scaling or some other way). Also, it needs to stop using the Brokers that died.

  1. https://kafka.apache.org/26/javadoc/org/apache/kafka/clients/admin/PartitionReassignment.html
  2. https://docs.cloudera.com/cdp-private-cloud-base/7.1.9/kafka-managing/topics/kafka-manage-cli-reassign-overview.html
  3. https://strimzi.io/blog/2022/09/16/reassign-partitions/

Links to this note