728x90
이전 포스트 : 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에도 메세지가 잘 출력되는것을 볼 수 있습니다.
내려갔다는 사실을 인지한 후 다시 올려주면 되겠습니다.
728x90
