[ 제 4강 관리 ] ReplicaFactor 변경

Replication Factor

이번에는 Replication Factor 변경하는 방법에 대해서 보겠습니다.

 

우선 이전 생성했던 example-topic 토픽에 정보를 확인해 보겠습니다. 

kafka-topics --zookeeper 192.168.2.77:2181,192.168.2.78:2181,192.168.2.78:2181/kafka --topic example-topic --describe

# 결과 값 확인

Topic:example-topic     PartitionCount:1        ReplicationFactor:1     Configs:
        Topic: example-topic    Partition: 0    Leader: 3       Replicas: 3     Isr: 3

 

그럼 이제 replica factor 변경을 해보겠습니다. 지금은 Replicas 3으로 되어있는데 변경해 볼께요

우선 json 파일 하나를 만들어야 합니다.

vi test.json
{"version":1,

"partitions":[
        {"topic" : "example-topic", "partition":0, "replicas":[1,2,3]}
]}

아래와 같은 명령어로 수정하면 됩니다.

 kafka-reassign-partitions --zookeeper 192.168.2.77:2181,192.168.2.78:2181,192.168.2.78:2181/kafka --reassignment-json-file test.json --execute
 
 
 # 결과 값
Current partition replica assignment

{"version":1,"partitions":[{"topic":"example-topic","partition":0,"replicas":[3],"log_dirs":["any"]}]}

Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.

 

그럼 다시 topic의 정보를 확인해 보겠습니다.

 kafka-topics --zookeeper 192.168.2.77:2181,192.168.2.78:2181,192.168.2.78:2181/kafka --topic example-topic --describe

# 결과 값
 Topic:example-topic     PartitionCount:1        ReplicationFactor:3     Configs:
        Topic: example-topic    Partition: 0    Leader: 3       Replicas: 1,2,3 Isr: 3,2,1

 

위에 보시면 이전과 다르게 Replicas와 Isr 의 값이 변경 된 것을 확인 하실 수 있습니다.