Skip to content

Commit 651e635

Browse files
lucasbruCopilot
andauthored
Update group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsTopology.java
Co-authored-by: Copilot <[email protected]>
1 parent d7a6d31 commit 651e635

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsTopology.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,9 +102,10 @@ public StreamsGroupDescribeResponseData.Topology asStreamsGroupDescribeTopology(
102102
return new StreamsGroupDescribeResponseData.Topology()
103103
.setEpoch(topologyEpoch)
104104
.setSubtopologies(
105-
subtopologies.entrySet().stream().map(
106-
entry -> asStreamsGroupDescribeSubtopology(entry.getKey(), entry.getValue())
107-
).toList()
105+
subtopologies.entrySet().stream()
106+
.sorted(Map.Entry.comparingByKey())
107+
.map(entry -> asStreamsGroupDescribeSubtopology(entry.getKey(), entry.getValue()))
108+
.toList()
108109
);
109110
}
110111

0 commit comments

Comments
 (0)