Cluster된 Kafka의 Broker(node)가 하나 내려간다면 일어나는 일

 

이전 포스트 : Kafka설치 with 클러스터링 (tistory.com)

이전 포스트에서 kb-broker01:9092, kb-broker02:9092, kb-broker03:9092 세개의 Broker로 클러스터 구성을 했었습니다.

 

여기에서 kb-broker03을 내린 후 어떻게 되는지 확인 해보았습니다.

 

브로커 내리기

3번 서버에 들어가서 브로커를 내렸습니다.

systemctl stop kafka

내리고 나서는

위와 같이 스프링부트 앱에서는 unavailable or invalid 라고 나옵니다.

 

 

Produce해보기

kb-broker03을 내리기 전과 같이 kb-broker01:9092,kb-broker0092,kb-broker03:9092 이렇게 3개의 브로커 주소를 모두 넣고 pub을 해보았습니다.

bin/kafka-console-producer.sh --broker-list kb-broker01:9092,kb-broker0092,kb-broker03:9092 --topic test_log

 

 

 

메세지가 손실된것 처럼 보이지만 Consumer가 서버에 하나 더 있습니다. 로컬에서 실행한 Consumer에도 메세지가 잘 출력되는것을 볼 수 있습니다.

 

내려갔다는 사실을 인지한 후 다시 올려주면 되겠습니다.