Gymterview
middle

Для чего нужен Consumer heartbeat thread?

Consumer Heartbeat Thread — это фоновый поток, который периодически отправляет сигналы (heartbeats) координатору группы, подтверждая, что потребитель жив и является частью группы.

Если потребитель не отправляет heartbeat в течение session.timeout.ms, координатор считает его мёртвым и инициирует перебалансировку для переназначения его партиций другим потребителям.

На собеседовании: важно знать связку двух таймаутов: session.timeout.ms — сколько ждать без heartbeat до объявления потребителя мёртвым; heartbeat.interval.ms — как часто отправлять heartbeat (обычно 1/3 от session.timeout.ms).