Improvement in stream ops in KafkaListener post processor (#4169)

moonyoungCHAE · web-flow · commit 32fa9fcd2d15 · 2025-11-18T12:05:12.000-05:00
Signed-off-by: moonyoungCHAE &lt;xpf_fl@naver.com&gt;
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java
@@ -547,15 +547,13 @@ private boolean processMainAndRetryListeners(KafkaListener kafkaListener, Object
 	}
 
 	private String[] getTopicsFromTopicPartitionOffset(String[] topics, TopicPartitionOffset[] tps) {
-		String[] retryableCandidates = topics;
-		if (retryableCandidates.length == 0 && tps.length > 0) {
-			retryableCandidates = Arrays.stream(tps)
+		if (topics.length == 0 && tps.length > 0) {
+			return Arrays.stream(tps)
 					.map(TopicPartitionOffset::getTopic)
 					.distinct()
-					.toList()
-					.toArray(new String[0]);
+					.toArray(String[]::new);
 		}
-		return retryableCandidates;
+		return topics;
 	}
 
 	private RetryTopicConfigurer getRetryTopicConfigurer() {

Original file line number	Diff line number	Diff line change
`@@ -547,15 +547,13 @@ private boolean processMainAndRetryListeners(KafkaListener kafkaListener, Object`
`547`	`547`	`}`
`548`	`548`
`549`	`549`	`private String[] getTopicsFromTopicPartitionOffset(String[] topics, TopicPartitionOffset[] tps) {`
`550`		`- String[] retryableCandidates = topics;`
`551`		`- if (retryableCandidates.length == 0 && tps.length > 0) {`
`552`		`- retryableCandidates = Arrays.stream(tps)`
	`550`	`+ if (topics.length == 0 && tps.length > 0) {`
	`551`	`+ return Arrays.stream(tps)`
`553`	`552`	`.map(TopicPartitionOffset::getTopic)`
`554`	`553`	`.distinct()`
`555`		`- .toList()`
`556`		`- .toArray(new String[0]);`
	`554`	`+ .toArray(String[]::new);`
`557`	`555`	`}`
`558`		`- return retryableCandidates;`
	`556`	`+ return topics;`
`559`	`557`	`}`
`560`	`558`
`561`	`559`	`private RetryTopicConfigurer getRetryTopicConfigurer() {`