Группа потребителей делит партиции топика между участниками: каждое сообщение обрабатывается одним участником группы.
А ещё Группа хранит общий прогресс — offset по партициям
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Внутри одной группы работает модель конкурирующих потребителей, а разные группы получают собственные копии потока — так одни и те же события могут независимо читать несколько сервисов. Позиция чтения хранится на группу, поэтому перезапуск участника не приводит к повторной обработке всего топика. Важное ограничение: партиция в каждый момент закреплена за одним участником, поэтому потребителей полезно иметь не больше, чем партиций.
Один верный вариант. Подумайте, потом откройте ответ.
Группа и распределение партиций, poll-цикл, heartbeat и таймауты, модели commit offset, ребаланс и роль идемпотентности.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto