comments

Author: lucasbru

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

@@ -1046,7 +1046,7 @@ public StreamsGroupDescribeResponseData.DescribedGroup asDescribedGroup(
                     .orElse(
                         topology.get(committedOffset)
                             .map(StreamsTopology::asStreamsGroupDescribeTopology)
-                            .orElse(null)
+                            .orElseThrow(() -> new IllegalStateException("There should always be a topology for a streams group."))
                     )
             );
         members.entrySet(committedOffset).forEach(

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

@@ -129,9 +129,9 @@ private StreamsGroupDescribeResponseData.TopicInfo asStreamsGroupDescribeTopicIn
             .setReplicationFactor(topicInfo.replicationFactor())
             .setTopicConfigs(
                 topicInfo.topicConfigs().stream().map(
-                    y -> new StreamsGroupDescribeResponseData.KeyValue()
-                        .setKey(y.key())
-                        .setValue(y.value())
+                    topicConfig -> new StreamsGroupDescribeResponseData.KeyValue()
+                        .setKey(topicConfig.key())
+                        .setValue(topicConfig.value())
                 ).toList()
             );
     }