Markierung des Koordinators für Gruppe (Kafka)

Question

Einer meiner Dienste hat vor ein paar Stunden aufgehört zu arbeiten. Ich habe den Server neu gestartet, aber dieser Consumer-Prozess registriert sich gerade nicht bei Kafka. Dies zeigt sich, wenn der Verbraucher gestartet wird:

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 

Ich habe 4 verschiedene Verbrauchergruppen und sie laufen gut. Irgendwelche Gedanken?

UPDATE

Seine seltsam wirklich. Wir mussten einen anderen unserer Consumer neu starten, und nach dem Neustart protokolliert der andere Verbraucher, der vor einer Sekunde noch funktionierte, den gleichen Fehler. Im Grunde haben wir jetzt zwei Verbraucherprozesse, die aus irgendeinem Grund keine Verbindung zu Kafka herstellen können.

Answer 1

meine eigene Frage zu beantworten:

Schließlich habe es zu arbeiten. Dies war kein Maklerproblem oder ein Verbraucherproblem. Was passiert ist, war, dass wir gegen 8:30 in der Nacht Firewall auf unseren beiden Kafka-Brokern aktiviert hatten. Die Verbraucher, die bereits mit Kafka verbunden waren, funktionierten gut. Wenn jedoch einer dieser Verbraucher neu gestartet wurde, konnten sie sich mit dem Koordinator verbinden. Wir haben die Firewall beider Kafka-Broker deaktiviert und die Daten wurden sofort an die Kunden weitergeleitet. Es ist ein temporärer Fix-Geldautomat, aber zumindest haben wir etwas.