SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing test failure

Browse Source 
Fixing Kafka Streams binder retry tests due to a
wrong conditional check.
This commit is contained in:
Soby Chacko
2020-11-05 11:04:25 -05:00
parent f1e3a0bdd6
commit 73921db3ec
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java
View File

@@ -139,7 +139,7 @@ final class KafkaStreamsBinderUtils {
}
}
if (StringUtils.hasText(properties.getRetryTemplateName())) {
if (!StringUtils.hasText(properties.getRetryTemplateName())) {
@SuppressWarnings("unchecked")
BeanDefinition retryTemplateBeanDefinition = BeanDefinitionBuilder
.genericBeanDefinition(