Kafka immer ein Verbraucher konsumieren die Thema Nachricht in einer Gruppe

Question

Ich habe zwei Consumer-Server mit der gleichen Gruppen-ID abonniert das gleiche Thema. Ein Kafka-Server läuft mit nur einer Partition. Soweit ich weiß, sollte die Nachricht nach dem Zufallsprinzip auf diesen beiden Consumer-Servern konsumiert werden. Aber jetzt scheint es immer die gleichen Consumer-Server A konsumieren Nachrichten, ein anderes konsumiert keine Nachrichten.Wenn ich Verbraucher-Server A zu stoppen, wird eine andere gut funktionieren. Was ich erwarte, dass sie Nachricht nach dem Zufallsprinzip konsumieren können.

Answer 1

Um zwei Consumer-Instanzen parallel verwenden zu können, benötigen Sie mindestens zwei Partitionen im Thema. Ein Consumer bindet sich an eine oder mehrere Partitionen eines Themas und andere Consumer mit derselben groupId beanspruchen keine Partitionen, an die bereits Konsumenten gebunden sind. Wenn ein Benutzer ausfällt/abstürzt, wird die Partition freigegeben und dann von einer anderen Consumer-Instanz abgeholt.