Ich habe 3 Broker, die mit der Broker-ID s 0 1 und 2 arbeiten. Der Consumer (Java-Client) ruft Broker 0 als Gruppenkoordinator auf und beginnt, Nachrichten korrekt zu konsumieren. Aber wenn der Broker 0, der der Gruppenkoordinator ist, nicht aktiv ist, macht der Konsument nichts und blockiert die poll () -Methode. Der Prozess wird nur fortgesetzt, wenn dieser Broker 0 ausgeführt wird.
Wie wird dieses Szenario der Änderung des Gruppenkoordinators im Java-Client gehandhabt?
Ich erhalte diesen Fehler, wenn der Gruppenkoordinator stirbt:
%Vor%Tags und Links apache-kafka kafka-consumer-api