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)