리눅스, kafka와 zookeeper 클러스터 상태에서의 장애 상황 테스트

장애 상황일 때 메시지 확인

장애 상황이 발생되기 이전에 주고 받았던 메시지는 어떻게 될 것인가?

 

새로운 메시지를 발행하면 자동으로 kafka에서 생성이 된다.

새로 생성되는 건 쉬운데 삭제는 어렵다. 유실되는 게 없도록 한다.

partition. replicas(메모리와 디스크에 저장을 해두는데 1번 디스크에 저장을 해뒀다.)

Isr(replica들 중에서 리더를 선출하여 데이터를 가져갈 수 있도록 해야 한다. 그게 몇 번 브로커에서 가능한지 나타내는 것)

Isr이 가리키는 브로커는 죽이면, Leader가 None이 된다.

 

따라서, 복사본과 파티션의 개수를 지정해줘야한다. (파티션은 늘리는 건 되는데 줄이는 건 안된다.)

/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server 서버들:9092 --replication-factor 3 --partitions 1 --topic 토픽주제이름

 

 

kafka가 설치되어있는 곳에 토픽 목록을 확인한다.

/opt/kafka/bin/kafka-topics.sh --list --bootstrap-server 서버들:9092

 

 

--describe는 토픽에 대한 자세한 내용을 보는 것

/opt/kafka/bin/kafka-topics.sh --bootstrap-server 서버들:9092 --topic 토픽주제이름 --describe

리더가 변경되는 것 확인