Почему происходит ребаланс в кафка?
Подскажите , почему может происходит ребаланс в кафке. Используем кафку 2.1.0, всего 5 нод кафки , на каждой стоит zookeeper. По какой то причине происходит ребаланс в группах кафки. В логах кафки вижу записи :
Preparing to rebalance group some-service in state PreparingRebalance with old generation 21668
(__consumer_offsets-47) (reason: removing member consumer-24-f5b9a9b1-ffed-4088-999b-378df9aaa71b on LeaveGroup)
(kafka.coordinator.group.GroupCoordinator)
Вроде понятно - вышел консьюмер и начался ребаланс. Но почему может отключиться консьюмер? По началу думал проблема в таймаутах (они слишком маленькие и тп, либо консьюмер не успевает обработать сообщение за отведенное время и кафка его выкидывает ) - я их увеличил до "не возможных" значений:
consumer:
max.poll.records: 1
max.poll.interval.ms: 900000
heartbeat.interval.ms: 200000
session.timeout.ms: 600000
Это не помогло, ребалансы продолжились. Подскажите что еще может вызвать ребаланс, имеет ли смысл так задирать таймауты, могут ли от этого быть "побочные" эффекты кроме того что мы поздно обнаружим "смерть" консьюмера.