Смещение конца Кафки 0,9.0 отодвинуло на ребаланс
У меня 3 потребителя работают над очередью кафки (6 разделов в 1 теме). Config:
enable.auto.commit: true
auto.commit.interval.ms : 1000
heartbeat.interval.ms: 4000
У меня проблема, когда происходит перебалансировка. Смещение смещено назад, как показано в примере журнала ниже.
INFO [2016-02-25 04:39:03,628] Consumer: Committed(Records = '3', Offset = '315377', Time = '2412ms')
INFO [2016-02-25 07:31:13,302] AbstractCoordinator: Attempt to heart beat failed since the group is rebalancing, try to re-join group.
INFO [2016-02-25 07:31:15,118] Consumer: Committed(Records = '3', Offset = '307104', Time = '0ms')
Я не вижу ошибок, которые потребители не могли бы совершить. Есть идеи, что может быть не так?