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(