Какая разница в Кафке между Координатором потребительской группы и лидером группы потребителей?

Question

я вижу ссылки на Кафка Координатор группы потребителей и лидер группы потребителей ...

1. В чем разница?

2. В чем преимущество разделения управления группой на два разных набора обязанностей?

Answer 1

Координатор группы потребителей является одним из брокеров, а лидер группы является одним из потребителей потребительской группы.

Координатор группы - это не что иное, как один из брокеров, который получает сердцебиение (или опрос сообщений) от всех потребителей группы потребителей. У каждой группы потребителей есть координатор группы. Если потребитель перестанет посылать пульс, координатор вызовет перебалансировку.

Когда потребитель хочет присоединиться к группе потребителей, он отправляет запрос JoinGroup координатору группы. Первым потребителем, присоединившимся к группе, становится лидер группы. Лидер получает список всех потребителей в группе от координатора группы (сюда будут входить все клиенты, которые недавно отправили пульс, и поэтому считаются живыми), и он отвечает за назначение подмножества разделов каждому потребителю. Он использует реализацию интерфейса PartitionAssignor для определения того, какие разделы должны обрабатываться каким бы то ни было пользователем. После принятия решения о назначении раздела потребитель-лидер отправляет список назначений GroupCoordinator, который отправляет эту информацию всем потребителям. Каждый потребитель видит свое собственное задание - лидер - единственный клиентский процесс, в котором есть полный список потребителей в группе и их назначения. Этот процесс повторяется каждый раз, когда происходит перебалансировка.