-
Create a custom reassignment plan (see attached file
inc-replication-factor.json). In this case we are going from replication factor of 1 to 3. -
Run Kafka partition reassignment script:
kafka-reassign-partitions --zookeeper $ZOOKEEPER_CONNECT \ --reassignment-json-file /home/liquidnt/inc-replication-factor.json \ --execute -
Verify if the assignment was successful