dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1316210535
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -1491,10 +1526,15 @@ public void
testConsumerGroupOffsetFetch
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314671160
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java:
##
@@ -631,4 +631,33 @@ public void testValidateOffsetCommit() {
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r131483
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupTest.java:
##
@@ -631,4 +631,33 @@ public void testValidateOffsetCommit() {
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314665557
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -181,10 +181,28 @@ public
List fetchOffsets(
Str
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314664510
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -181,10 +181,28 @@ public
List fetchOffsets(
Str
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314663349
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java:
##
@@ -823,9 +823,17 @@ public void validateOffsetCommit(
/**
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314661887
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -1409,6 +1444,82 @@ public void
testFetchAllOffsetsAtDifferen
dajac commented on code in PR #14321:
URL: https://github.com/apache/kafka/pull/14321#discussion_r1314590003
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -538,17 +537,46 @@ public void validateOffsetCommit(
if