после рестарта/добавления/падения
{
timestamp: '2021-06-15T23:22:38.712Z',
logger: 'kafkajs',
groupId: 'prod_*****',
memberId: 'prod-****',
leaderId: 'prod-*********',
isLeader: true,
memberAssignment: { 'prod-******': [ 12, 4 ] },
groupProtocol: 'RoundRobinAssigner',
Duration: 59147
}
1 топик в 1 одной группе (24 партиции на топик)
консьюмер:
sessionTimeout 100000
heartbeatInterval 3000
Куда копать ?
проблему решил , rebalanceTimeout дефолтное значение 60000mc
Обсуждают сегодня