[GitHub] [kafka] jeffkbkim commented on a diff in pull request #13901: KAFKA-14462; [20/N] Refresh subscription metadata on new metadata image

2023-06-28 Thread via GitHub
jeffkbkim commented on code in PR #13901: URL: https://github.com/apache/kafka/pull/13901#discussion_r1245682672 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java: ## @@ -728,6 +794,81 @@ public void replay( }

[GitHub] [kafka] jeffkbkim commented on a diff in pull request #13901: KAFKA-14462; [20/N] Refresh subscription metadata on new metadata image

2023-06-28 Thread via GitHub
jeffkbkim commented on code in PR #13901: URL: https://github.com/apache/kafka/pull/13901#discussion_r1245712559 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java: ## @@ -141,7 +141,7 @@ public static class TimeAndEpoch { *