root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

comments

This commit is contained in:
Lucas Brutschy 2025-10-07 16:10:59 +02:00
parent b0d6964833
commit e14d5b01cb
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java
View File

@ -150,7 +150,7 @@ public class StreamsGroup implements Group {
/**
* The topology epoch for which the subscribed topics identified by metadataHash are validated.
*/
protected final TimelineInteger validatedTopologyEpoch;
private final TimelineInteger validatedTopologyEpoch;
/**
* The metadata hash which is computed based on the all subscribed topics.

4
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
View File

@ -9752,7 +9752,7 @@ public class GroupMetadataManagerTest {
context.replay(StreamsCoordinatorRecordHelpers.newStreamsGroupMemberRecord(streamsGroupId, memberBuilder2.build()));
context.replay(StreamsCoordinatorRecordHelpers.newStreamsGroupTargetAssignmentRecord(streamsGroupId, memberId2, assignment));
context.replay(StreamsCoordinatorRecordHelpers.newStreamsGroupCurrentAssignmentRecord(streamsGroupId, memberBuilder2.build()));
context.replay(StreamsCoordinatorRecordHelpers.newStreamsGroupMetadataRecord(streamsGroupId, epoch + 2, 0, -1));
context.replay(StreamsCoordinatorRecordHelpers.newStreamsGroupMetadataRecord(streamsGroupId, epoch + 2, 0, 0));
List<StreamsGroupDescribeResponseData.DescribedGroup> actual = context.groupMetadataManager.streamsGroupDescribe(List.of(streamsGroupId), context.lastCommittedOffset);
StreamsGroupDescribeResponseData.DescribedGroup describedGroup = new StreamsGroupDescribeResponseData.DescribedGroup()
@ -9783,7 +9783,7 @@ public class GroupMetadataManagerTest {
)
)
)
.setGroupState(StreamsGroup.StreamsGroupState.NOT_READY.toString())
.setGroupState(StreamsGroup.StreamsGroupState.ASSIGNING.toString())
.setGroupEpoch(epoch + 2);
assertEquals(1, actual.size());
assertEquals(describedGroup, actual.get(0));

6
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpersTest.java
View File

@ -257,13 +257,13 @@ class StreamsCoordinatorRecordHelpersTest {
new ApiMessageAndVersion(
new StreamsGroupMetadataValue()
.setEpoch(42)
.setMetadataHash(42)
.setValidatedTopologyEpoch(43),
.setMetadataHash(43)
.setValidatedTopologyEpoch(44),
(short) 0
)
);
assertEquals(expectedRecord, StreamsCoordinatorRecordHelpers.newStreamsGroupMetadataRecord(GROUP_ID, 42, 42, 43));
assertEquals(expectedRecord, StreamsCoordinatorRecordHelpers.newStreamsGroupMetadataRecord(GROUP_ID, 42, 43, 44));
}
@Test