Consumer group в Kafka?

Middle
744 просмотров
AFK Offer AI

Consumer group — это группа консюмеров, которые совместно читают топик. Каждая партиция назначается только одному консюмеру внутри группы, что даёт параллелизм без дублирования. Если консюмер падает, Kafka перебалансирует партиции между оставшимися.

Ключевые моменты:

  • Количество консюмеров в группе не должно превышать количество партиций — лишние будут простаивать
  • Offset коммитится per-group, поэтому разные группы читают независимо
  • Ребалансировка происходит автоматически при добавлении/удалении консюмера
Это основной механизм горизонтального масштабирования чтения в Kafka.

Следующий вопрос

Как работает CPU profiling?