Dongnuo Lyu created KAFKA-21189:
-----------------------------------

             Summary: Classic members in a consumer group are loaded with the 
group level session timeout
                 Key: KAFKA-21189
                 URL: https://issues.apache.org/jira/browse/KAFKA-21189
             Project: Kafka
          Issue Type: Bug
            Reporter: Dongnuo Lyu
            Assignee: Dongnuo Lyu


When a consumer group is reconstructed on coordinator load, 
`GroupMetadataManager#onLoaded` schedules every member's session timer through 
`scheduleConsumerGroupSessionTimeout(groupId, memberId)`, which uses the group 
level `consumerGroupSessionTimeoutMs(groupId)`

 

Members that joined with the classic protocol should use their own 
`sessionTimeoutMs` in `ConsumerGroupMemberMetadataValue.ClassicMemberMetadata`



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to