Do not refresh metadata eagerly:

2015-05-22 17:34:45 -04:00
parent 38856ee984
commit d475a79d83
1 changed files with 0 additions and 2 deletions
--- 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