[컴] kafka 실행시 cluster ID 에러

카프카 사용 해 보기 / 실행시 에러 / 실행하면 죽는다

kafka 실행시 cluster ID 에러

kafka 를 실행하니 다음과 같은 error 가 발생했다. 요점은 cluster ID 가 맞지 않는다는 것이다.

아래 로그에 보면 Cluster ID 2개가 보인다.

• F_YZNosISlGO7PKp4gLACQ
• guOHkNv4R-q9dMRbtE3VoA

# kafka.log
...

[2021-06-06 08:46:42,397] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentClusterIdException: The Cluster ID guOHkNv4R-q9dMRbtE3VoA doesn't match stored clusterId Some(F_YZNosISlGO7PKp4gLACQ) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
    at kafka.server.KafkaServer.startup(KafkaServer.scala:218)
    at kafka.Kafka$.main(Kafka.scala:109)
    at kafka.Kafka.main(Kafka.scala)
[2021-06-06 08:46:42,398] INFO shutting down (kafka.server.KafkaServer)
...

해결방법

<log.dirs>/meta.properties 에서 client ID 를 수정해 주면 된다.

• log.dirs : kafka 설치하기 참고

kafka@myuser-VirtualBox:~/logs$ cat meta.properties
#
#Sat Jun 05 21:14:31 KST 2021
cluster.id=F_YZNosISlGO7PKp4gLACQ
version=0
broker.id=0

위의 meta.properties 에서 F_YZNosISlGO7PKp4gLACQ 를 guOHkNv4R-q9dMRbtE3VoA 로 변경해 주자.

이제 kafka 를 다시 실행하자.

sudo systemctl start kafkat
tail -f <kafka_root>/kafka.log

Reference

1. Kafka error – Cluster ID doesn’t match stored clusterId in meta.properties – Amal G Jose