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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
