diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java index ca704384c..2a49cfd14 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/function/KafkaStreamsBindableProxyFactory.java @@ -88,6 +88,7 @@ public class KafkaStreamsBindableProxyFactory extends AbstractBindableProxyFacto @Override public void afterPropertiesSet() { + populateBindingTargetFactories(beanFactory); Assert.notEmpty(KafkaStreamsBindableProxyFactory.this.bindingTargetFactories, "'bindingTargetFactories' cannot be empty");