Le marquage de la coordonnatrice de la mort pour le groupe(Kafka)
Une de mes services arrêté de travailler il y a quelques heures. J'ai redémarré le serveur, mais ce processus n'est tout simplement pas l'enregistrement de Kafka. C'est ce que s'affiche lorsque le consommateur est en route :
2017-04-21 10:22:54.887 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : Revoking previously assigned partitions [] for group mysql-conversions-group
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked:[]
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : (Re-)joining group mysql-conversions-group
2017-04-21 10:22:54.915 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : Marking the coordinator li819-138.members.linode.com:9092 (id: 2147483646 rack: null) dead for group mysql-conversions-group
J'ai 4 différents groupes de consommateurs et ils fonctionnent très bien. Toutes les pensées?
Mise à JOUR
Son étrange, vraiment. Nous avons eu à redémarrer une autre de nos Consommateurs, et après le redémarrage, l'autre à la consommation qui fonctionnait bien il y a une seconde qui est maintenant de la connexion la même erreur.
Fondamentalement, nous avons maintenant 2 consommateur processus qui ne peut pas se connecter à Kafka pour une raison quelconque.
OriginalL'auteur Ankush92 | 2017-04-21
Vous devez vous connecter pour publier un commentaire.
Pour répondre à ma propre question:
Enfin réussi à le faire fonctionner. Ce n'était pas un courtier en question ou d'une problématique de consommation.
Ce qui est arrivé, nous a permis de pare-feu sur nos deux Kafka courtiers autour de 8:30 dans la nuit. Les consommateurs qui ont déjà été connecté avec Kafka fonctionnent très bien. Toutefois, lorsque l'un de ces consommateurs ont repris, ils ont été incapable de se connecter au nœud de coordonnateur. Nous avons désactivé le pare-feu sur le Kafka de courtiers, et les données sont immédiatement transmises aux consommateurs. C'est une solution temporaire ATM, mais nous avons au moins quelque chose.
OriginalL'auteur Ankush92