Gymterview
middle

Какие настройки консюмера существуют?

Настройки консюмера определяют подключение, смещения, группы и поведение при чтении.

Настройка Описание Пример
bootstrap.servers Список брокеров для подключения localhost:9092
group.id Идентификатор группы потребителей my-consumer-group
auto.offset.reset Поведение при отсутствии offset earliest / latest
enable.auto.commit Автоматический коммит offset true / false
auto.commit.interval.ms Интервал между авто-коммитами 5000
max.poll.records Максимальное количество сообщений за один poll() 500
session.timeout.ms Таймаут до признания потребителя недоступным 10000
client.rack Метка серверной стойки или дата-центра rack-1

Что такое Rack в контексте Kafka

Rack — это метка физического местоположения брокеров. Задаётся через broker.rack для управления репликацией данных между разными физическими машинами или дата-центрами.

Преимущества использования client.rack:

  • Снижение задержек — Kafka предпочитает чтение из реплик в том же rack
  • Повышенная отказоустойчивость — реплики в разных физических местах
  • Лучшее использование ресурсов — равномерное распределение нагрузки

На собеседовании: частый вопрос — что такое auto.offset.reset. earliest означает чтение с самого начала (если offset не найден), latest — чтение только новых сообщений. Это влияет только на первое подключение группы или при сбросе offset.