dajac commented on code in PR #15364: URL: https://github.com/apache/kafka/pull/15364#discussion_r1521508636
########## group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java: ########## @@ -931,17 +920,14 @@ public void testGroupEpochBumpWhenNewStaticMemberJoins() { ConsumerGroupMember expectedMember3 = new ConsumerGroupMember.Builder(memberId3) .setMemberEpoch(11) + .setState(MemberState.UNRELEASED_PARTITIONS) .setInstanceId(memberId3) .setPreviousMemberEpoch(0) - .setTargetMemberEpoch(11) .setClientId("client") .setClientHost("localhost/127.0.0.1") .setRebalanceTimeoutMs(5000) .setSubscribedTopicNames(Arrays.asList("foo", "bar")) .setServerAssignorName("range") - .setPartitionsPendingAssignment(mkAssignment( Review Comment: It is a matter of the difference between the owned partitions and the assignment. The field was not really used in the end so I thought that it is better to remove it to save space. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org