diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
index 40ca234b4..09307efb1 100644
--- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
+++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java
@@ -191,7 +191,11 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl
 				Set<String> defaultCandidateConfigurations = new HashSet<>();
 				for (Map.Entry<String, BinderConfiguration> binderConfigurationEntry : this.binderConfigurations
 						.entrySet()) {
-					if (binderConfigurationEntry.getValue().isDefaultCandidate()) {
+					if ("integration".equals(binderConfigurationEntry.getKey())) {
+						defaultCandidateConfigurations.add(binderConfigurationEntry.getKey());
+						break;
+					}
+					else if (binderConfigurationEntry.getValue().isDefaultCandidate()) {
 						defaultCandidateConfigurations
 								.add(binderConfigurationEntry.getKey());
 					}