[1] partition - replication factor test ( json 파일로 topic leader 변경 및 replication factor 증량 )

[ test 방법 ]

  (ex) partition 1 - replication factor 1 일 경우

$>bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic basic-consumer

토픽 생성 결과

broker 1 상태

broker 2 상태

[ partition 증량 방법 ]

1.json 파일 작성

( json 파일을 통해 leader 변경 및 replication factor +1 증량 )

2.kafka cli 명령어를 통해 json 파일 topic에 적용

$>bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic basic-consumer

[ test 결과 ]

partition 1 :  replication factor 1  / (topic : basic-consumer_240509)

partition 1 :  replication factor 2 / (topic : basic-consumer_240509 → json 파일을 통해  replicaion factor 증설 )

 

partition 2 :  replication factor 1

partition 2 :  replication factor 2

partition 2 :  replication factor 3

partition 3 :  replication factor 1

partition 3 :  replication factor 2

partition 3 :  replication factor 3