Aller au contenu principal

Troubleshooting

Erreur au démarrage de Kafka​

Présence dans les logs de ce type de message :

{"time": "2024-03-27 10:03:35,585", "level": "ERROR", "message":"{Fatal error during KafkaServer startup. Prepare to shutdown}", "class":"kafka.server.KafkaServer", "thread": "main"}
kafka.common.InconsistentClusterIdException: The Cluster ID hSI6VBP7TGubgZqurUiQsA doesn't match stored clusterId Some(zmAzxOi5QRytTvBSK2ns3w) 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)

Utilisation de l'interface en ligne de commande de Kafka​

kubectl -n "<namespace>" exec "<pod-name>" -- /opt/kafka/bin/kafka-cluster.sh cluster-id --bootstrap-server localhost:9092
  • Exemple
kubectl -n "shared-stream" exec "kafka-kafka-0" -- /opt/kafka/bin/kafka-cluster.sh cluster-id --bootstrap-server localhost:9092
Cluster ID: hSI6VBP7TGubgZqurUiQsA

Supprimer le fichier de configuration de Kafka​

info

L'utilisation d'un signe = (égal) dans la commande permet d'etre agnostique vis a vis de l'instance sur laquelle on lance la commande.

kubectl -n "<namespace>" exec "<pod-name>" -- sh -c 'rm /var/lib/kafka/services_donnees/kafka-log?/meta.properties'
  • Exemple :
kubectl -n "shared-stream" exec "kafka-kafka-0" -- sh -c 'rm /var/lib/kafka/services_donnees/kafka-log?/meta.properties'

Explications​

Cela peut se produire si un mise à jour du cluster a été faite de manière incorrecte.