Remove unnecessary stream() before forEach()

Signed-off-by: Tran Ngoc Nhan <[email protected]>

Author: ngocnhan-tran1996

spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerGroupSequencer.java

@@ -201,7 +201,7 @@ public void initialize() {
 			this.currentGroup = this.iterator.next();
 			this.groups.forEach(grp -> {
 				Collection<String> ids = grp.getListenerIds();
-				ids.stream().forEach(id -> {
+				ids.forEach(id -> {
 					MessageListenerContainer container = this.registry.getListenerContainer(id);
 					if (Objects.requireNonNull(container).getContainerProperties().getIdleEventInterval() == null) {
 						container.getContainerProperties().setIdleEventInterval(this.defaultIdleEventInterval);

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/DefaultDestinationTopicProcessor.java

@@ -46,7 +46,6 @@ public void processDestinationTopicProperties(Consumer<DestinationTopic.Properti
 												Context context) {
 		context
 				.properties
-				.stream()
 				.forEach(destinationPropertiesProcessor);
 	}