Consumer Pause & Resume funktioniert auf ConsumerGroup-Ebene? - Apache-Kafka, Kafka-Verbraucher-API

Ich gehe durch die Kafka Pause & Lebenslauf Funktion in Verbraucher.

Ich frage mich, ob diese Pause für alle Verbraucher in einer Verbrauchergruppe auftritt? Ich habe auch hier gelesen, dass der Pausestatus für die Verbrauchergruppe auf Kafka Server beibehalten wird.

Wenn jemand die oben genannten Fragen beantworten / auf die richtigen Ressourcen hinweisen kann, wäre es hilfreich.

Antworten:

Pause ist nur die normale Aktion des Konsumenten,nicht die Entfernung aus der Verbrauchergruppe. Da die API-Dokumentation besagt, dass Pause () den Abruf von der Partition anhält, hat diese Methode keinen Einfluss auf die Partitionsabonnements. Es wird also nicht aus der Verbrauchergruppe entfernt und führt nicht zur Neugewichtung der Gruppe.

wenn diese Pause für alle Verbraucher auftrittIn einer Consumer-Gruppe vorhanden, die dazu führt, dass der lagEndOffset dieser Gruppe für jede Partition dieses Themas nur in diesem Zeitraum erhöht wird. Da das Nachrichtenmodell von Kafka ein PULL-Modell ist, hängt es von dem Konsumenten ab, wie das Abrufen zu holen ist. Und jeder Verbraucher in der gleichen Gruppe beeinflusst sich nicht gegenseitig, wenn er pausiert oder fortfährt. Weil es keinen Ausgleich schafft.

Du könntest das lesen http://kafka.apache.org/documentation.html#theconsumer && http://kafka.apache.org/documentation.html#impl_consumerregistration