Spring/spring-integration-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-161: Use TopicUtils to ensureTopicCreated

Browse Source 
Fixes GH-161 (https://github.com/spring-projects/spring-integration-samples/issues/161)
This commit is contained in:
Artem Bilan
2016-02-17 12:50:35 -05:00
parent 1310fd57e5
commit 55b2cfb49f
1 changed files with 2 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java
View File

@@ -20,7 +20,6 @@ import java.util.Collections;
import java.util.Map;
import java.util.Properties;
import org.I0Itec.zkclient.ZkClient;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.beans.factory.annotation.Value;
@@ -48,16 +47,13 @@ import org.springframework.integration.kafka.support.ProducerConfiguration;
import org.springframework.integration.kafka.support.ProducerFactoryBean;
import org.springframework.integration.kafka.support.ProducerMetadata;
import org.springframework.integration.kafka.support.ZookeeperConnect;
import org.springframework.integration.kafka.util.TopicUtils;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.support.GenericMessage;
import kafka.admin.AdminUtils;
import kafka.common.TopicExistsException;
import kafka.utils.ZKStringSerializer$;
/**
* @author Gary Russell
* @since 4.2
@@ -186,12 +182,7 @@ public class Application {
@Override
public void start() {
ZkClient client = new ZkClient(this.zkConnect, 10000, 10000, ZKStringSerializer$.MODULE$);
try {
AdminUtils.createTopic(client, this.topic, 1, 1, new Properties());
}
catch (TopicExistsException e) {
}
TopicUtils.ensureTopicCreated(this.zkConnect, this.topic, 1, 1);
this.running = true;
}