Чтобы независимые получатели Kafka читали одни и те же сообщения, каждому логическому подписчику назначают отдельную consumer group. Внутри одной обычной группы partition распределяются между участниками.
Как сделать broadcast на Kafka (чтобы все консьюмеры читали сообщение)?
Чтобы независимые получатели Kafka читали одни и те же сообщения, каждому логическому подписчику назначают отдельную consumer group. Внутри одной обычной группы partition распределяются между участниками.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
Чтобы независимые получатели Kafka читали одни и те же сообщения, каждому логическому подписчику назначают отдельную consumer group. Внутри одной обычной группы partition распределяются между участниками.
Группа представляет отдельную подписку и хранит собственные offsets. Если каждый экземпляр приложения должен получать все события, ему нужна независимая подписка с продуманным стабильным group.id. Случайная новая группа при каждом рестарте меняет поведение чтения истории в зависимости от offsets и auto.offset.reset. Дополнительно учитывают retention: отдельные группы не гарантируют доступ к уже удалённым сообщениям.