diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java index 3203878c..e4167d8e 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsFunctionProcessor.java @@ -168,7 +168,7 @@ public class KafkaStreamsFunctionProcessor extends AbstractKafkaStreamsBinderPro } private void traverseReturnTypeForComponentBeans(Map resolvableTypeMap, ResolvableType currentOutputGeneric, - Set inputs, Iterator iterator, Class outputRawclass) { + Set inputs, Iterator iterator, Class outputRawclass) { if (outputRawclass != null && !outputRawclass.equals(Void.TYPE)) { ResolvableType iterableResType = currentOutputGeneric; int i = 1;