advanced
Consumer group
Масштабируйте consumption, разделяя partitions или queue work между instances, сохраняя broker-specific delivery и ordering model.
Consumer group делит work: каждая partition или queue shard обрабатывается не более чем одним member, enabling horizontal scale. Rebalance при join/leave members — краткая пауза consumption.
Компромисс: scale-out против rebalance disruption и лимита max consumers ≈ partition count в Kafka.
На интервью: почему десять consumers на three-partition topic работают только три; rebalance storms при deploys.
Типовые ошибки: несколько groups читают topic без понимания independent offsets; частые rolling deploys и rebalance lag.
Чеклист:
- Size partitions под target parallelism.
- Cooperative rebalance и static membership где поддерживается.
- Stagger deploys или pause-aware rebalancing.
- Rebalance duration и lag per partition.