Demo: kafka-reassign-partitions¶

./bin/kafka-server-start.sh config/server.properties \
  --override broker.id=10 \
  --override log.dirs=/tmp/kafka-logs-10 \
  --override listeners=PLAINTEXT://:9192

./bin/kafka-server-start.sh config/server.properties \
  --override broker.id=20 \
  --override log.dirs=/tmp/kafka-logs-20 \
  --override listeners=PLAINTEXT://:9292

./bin/kafka-server-start.sh config/server.properties \
  --override broker.id=30 \
  --override log.dirs=/tmp/kafka-logs-30 \
  --override listeners=PLAINTEXT://:9392

./bin/kafka-topics.sh \
  --bootstrap-server :9192 \
  --create \
  --topic demo-reassign-partitions \
  --replication-factor 2 \
  --partitions 1

./bin/kafka-topics.sh \
  --bootstrap-server :9192 \
  --describe \
  --topic demo-reassign-partitions

Topic: demo-reassign-partitions TopicId: J3ginqnTTg-LjVoI20dqqw PartitionCount: 1 ReplicationFactor: 2 Configs: segment.bytes=1073741824
 Topic: demo-reassign-partitions Partition: 0 Leader: 10 Replicas: 10,20 Isr: 10,20

{
  "partitions": [
    {
      "topic": "demo-reassign-partitions",
      "partition": 1,
      "replicas": [
        20,
        30
      ]
    }
  ],
  "version": 1
}

$ ./bin/kafka-reassign-partitions.sh \
  --bootstrap-server :9192 \
  --generate \
  --topics-to-move-json-file reassign-partitions.json \
  --broker-list 10,20,30

$ ./bin/kafka-reassign-partitions.sh \
  --bootstrap-server :9192 \
  --verify \
  --reassignment-json-file reassign-partitions.json