В моем проекте используется Kafaka 0.10.1.0, и я рылся в источнике, пытаясь немного узнать.
У меня был вопрос о протоколе Kafka для обмена метаданными, связанными с группами, это одноранговый узел протокол типа -to-peer, в котором Координатор для данной группы потребителей работает на клиентских машинах?
В документации для org. apache .kafka.clients.consumer.internals.AbstractCoordinator упоминается один шаг в протоколе :
<li>Group/Leader Selection: The coordinator select the members of the group and chooses one member
as the leader.</li>
Итак, похоже, что logi c лидера группы работает на стороне клиента. Я думаю, это было бы хорошо для масштабируемости, разгрузки от брокера, но я хотел подтвердить с экспертом Kafa, что я пришел к правильному выводу. Спасибо!