Red de conocimiento informático - Aprendizaje de programación - Agregar consumidores al grupo de consumidores de Kafka

Agregar consumidores al grupo de consumidores de Kafka

Este artículo está basado en Kafka 2.8

Los grupos de consumidores son un mecanismo de mensajería escalable en Kafka que puede lograr el equilibrio de carga del consumidor y la expansión horizontal de las capacidades de consumo del consumidor. Los consumidores *** del mismo grupo de consumidores comparten el ID del grupo.

Puede aumentar su poder de consumo agregando varios consumidores, entonces, ¿por qué necesita un mecanismo de grupo de consumidores? ¿Por qué tener grupos? Sin un grupo, ¿qué podría ser mejor que simplemente agregar más consumidores para ampliar el poder adquisitivo?

Agregar un consumidor a un grupo de consumidores es un proceso dinámico, es decir, crear un grupo de consumidores en el cliente, crear un cliente consumidor, cargar el tema suscrito y suscribir al consumidor actual al tema actual. Cuando necesite agregar varios consumidores, puede crear un grupo de consumidores, iniciar un cliente consumidor con el mismo tema y nombre de grupo y luego agregar un segundo consumidor. Por analogía, se pueden agregar varios consumidores.

Vista del lado del servidor de información de grupos y consumidores

Como se muestra arriba, se crea un grupo de consumidores ReduxConsumerGroup y se asignan dos particiones [0, 1] al mismo consumidor que.

Vista del lado del servidor de información de grupos y consumidores

Para el mismo tema, se asignan dos particiones a dos consumidores diferentes.

Simplemente salga del cliente de consumo.

Vista del lado del servidor de información de grupos y consumidores

Como puede ver, el primer consumidor desapareció y la partición del tema se asignó al segundo consumidor

p >

Vista del lado del servidor de información de grupos y consumidores

Se han eliminado todos los consumidores.