From 96eda35da578bdbd717655189ede44f6dbc07a6c Mon Sep 17 00:00:00 2001
From: Tom Bentley <tbentley@redhat.com>
Date: Tue, 23 May 2017 12:06:26 +0100
Subject: [PATCH] Respect any existing auto.create.topics.enable when creating
 a server

---
 debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java b/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
index 3dbb3f45a..b130619e7 100644
--- a/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
+++ b/debezium-core/src/test/java/io/debezium/kafka/KafkaServer.java
@@ -155,7 +155,7 @@ public Properties config() {
         runningConfig.setProperty(KafkaConfig.ZkConnectProp(), zookeeperConnection());
         runningConfig.setProperty(KafkaConfig.BrokerIdProp(), Integer.toString(brokerId));
         runningConfig.setProperty(KafkaConfig.HostNameProp(), "localhost");
-        runningConfig.setProperty(KafkaConfig.AutoCreateTopicsEnableProp(), String.valueOf(Boolean.TRUE));
+        runningConfig.setProperty(KafkaConfig.AutoCreateTopicsEnableProp(), String.valueOf(config.getOrDefault(KafkaConfig.AutoCreateTopicsEnableProp(), Boolean.TRUE)));
         // 1 partition for the __consumer_offsets_ topic should be enough
         runningConfig.setProperty(KafkaConfig.OffsetsTopicPartitionsProp(), Integer.toString(1));
         return runningConfig;