Gymterview
junior

Как потребители получают сообщения от брокера?

Kafka использует pull-модель для доставки сообщений. Потребители сами запрашивают данные у брокеров через poll(), а не получают push от брокера.

Потребитель отправляет запрос, указывая топик, партицию и начальное смещение. Брокер отвечает сообщениями с объёмом до указанного максимального предела в байтах.

На собеседовании: pull-модель — это осознанный выбор архитектуры Kafka. Преимущества: потребитель контролирует скорость чтения, не перегружается при пиках, может перечитать данные. Недостаток: при отсутствии данных потребитель тратит ресурсы на пустые poll (решается через long polling с таймаутом).