From 73921db3ec457e7dbfbc74b01cc93e71907f6e2e Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 5 Nov 2020 11:04:25 -0500 Subject: [PATCH] Fixing test failure Fixing Kafka Streams binder retry tests due to a wrong conditional check. --- .../stream/binder/kafka/streams/KafkaStreamsBinderUtils.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/KafkaStreamsBinderUtils.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java index e57fa0e4d..f1c1bb831 100644 --- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java +++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java @@ -139,7 +139,7 @@ final class KafkaStreamsBinderUtils { } } - if (StringUtils.hasText(properties.getRetryTemplateName())) { + if (!StringUtils.hasText(properties.getRetryTemplateName())) { @SuppressWarnings("unchecked") BeanDefinition retryTemplateBeanDefinition = BeanDefinitionBuilder .genericBeanDefinition(