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.