Перекос ключей (один популярный key) или плохой partitioner шлёт трафик в одну партицию: растёт latency/lag на ней. Лечат сменой ключа, солью, отдельным топиком, пересмотром модели.
Разбор
- Мониторьте bytes/messages per partition.
- Соль в key ломает порядок внутри сущности — компромисс.
- Больше партиций hot key не спасёт.
- Иногда нужен локальный агрег до Kafka.
Итог
Hot partition лечится ключами/моделью, не слепым scale-out.