From 9644f2dbbf086420cf712b5698d35ae41275c45f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 12 Apr 2019 15:21:16 -0400 Subject: [PATCH] Kafka Streams multiple function issues Fixing a bug around when we have muliple beans defined as functions/csonumers in the new Kafka Streams binder functional support. Polishing Resolves #636 --- .../binder/kafka/streams/function/FunctionDetectorCondition.java | 1 + .../streams/function/KafkaStreamsFunctionBeanPostProcessor.java | 1 + 2 files changed, 2 insertions(+) diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java index 18f0fd535..a55ce03b1 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/FunctionDetectorCondition.java @@ -18,6 +18,7 @@ package org.springframework.cloud.stream.binder.kafka.streams.function; import java.lang.reflect.Method; import java.util.HashMap; + import java.util.Map; import java.util.function.Consumer; import java.util.function.Function; diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java index d13f4c6c2..a85b14412 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsFunctionBeanPostProcessor.java @@ -21,6 +21,7 @@ import java.util.Map; import java.util.TreeMap; import java.util.function.Consumer; import java.util.function.Function; + import java.util.stream.Stream; import org.springframework.beans.BeansException;