카테고리 없음

[Kafka] The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong

omelette master 2022. 11. 14. 11:40

상황

  • kubernetes 환경에서 deploy 별 kafka3개를 띄워서 사용중에 있었음, 볼륨은 1개

  • kafka 재 실행 하다 보니까 저렇게 오류 발생

오류

kafka.common.InconsistentClusterIdException: The Cluster ID * doesn't match stored clusterId Some(*) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.

처리

rm -f $KAFKA_LOG_DIRS/meta.properties

3개 띄워서 사용중 이였음으로 3개 전부 삭제
혹은
log에 출력된 내용의 cluster id를 meta.properties의 cluster.id에 넣어준다.

이후 재 배포 (* 이미 서비스를 종료 한뒤에 작업을 했던거여서 재 배포를 진행)