lucasbru commented on code in PR #19114:
URL: https://github.com/apache/kafka/pull/19114#discussion_r1981494265
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##########
@@ -7160,6 +7881,34 @@ private int shareGroupHeartbeatIntervalMs(String
groupId) {
.orElse(config.shareGroupHeartbeatIntervalMs());
}
+ /**
+ * Get the session timeout of the provided streams group.
+ */
+ private int streamsGroupSessionTimeoutMs(String groupId) {
+ return 45000;
Review Comment:
These are left constant for now. To be replaced by calls to the
`GroupConfigManager` when @aliehsaeedii introduces the group configurations.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
