diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/core/DefaultConnectionFactory.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/core/DefaultConnectionFactory.java
index b50fdcc895..98f5c084e1 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/core/DefaultConnectionFactory.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/core/DefaultConnectionFactory.java
@@ -78,8 +78,6 @@ public class DefaultConnectionFactory implements InitializingBean, ConnectionFac
 	@Override
 	public void afterPropertiesSet() throws Exception {
 		Assert.notNull(this.configuration, "Kafka configuration cannot be empty");
-		refreshMetadata(this.configuration.getDefaultTopic() == null ? Collections.<String>emptyList() :
-				Collections.singletonList(this.configuration.getDefaultTopic()));
 	}
 
 	@Override