после рестарта/добавления/падения 
                  
                  
                  
                  
                  
                  {
                  
                  
                    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
Обсуждают сегодня