From d5a72a29d0c6441d7982de404a348a9c63ef3018 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 17 Dec 2019 10:55:27 +0100 Subject: [PATCH] GH-815 polishing Resolves #816 --- .../kafka/streams/AbstractKafkaStreamsBinderProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java index e4f12574e..94ce0f573 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java @@ -191,7 +191,7 @@ public abstract class AbstractKafkaStreamsBinderProcessor implements Application if (StringUtils.isEmpty(connectionString)) { connectionString = (String) propertySources.get(bindingProperties.getBinder() + "-kafkaStreamsBinderEnv").getProperty("spring.cloud.stream.kafka.binder.brokers"); } - if (!StringUtils.isEmpty(connectionString)) { + else { streamConfigGlobalProperties.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, connectionString); }