From d475a79d83e41d0b7d053bb87e2a6893fd2ea1ad Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Fri, 22 May 2015 17:34:45 -0400 Subject: [PATCH] Do not refresh metadata eagerly: --- .../integration/kafka/core/DefaultConnectionFactory.java | 2 -- 1 file changed, 2 deletions(-) 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.emptyList() : - Collections.singletonList(this.configuration.getDefaultTopic())); } @Override