diff --git a/.gitignore b/.gitignore
index 318d429..41d2931 100644
--- a/.gitignore
+++ b/.gitignore
@@ -10,3 +10,4 @@ autodoc/**
 /target
 .lein-repl-history
 /tmp
+/logs
diff --git a/dev-resources/log4j.properties b/dev-resources/log4j.properties
index 5555652..041cf9c 100644
--- a/dev-resources/log4j.properties
+++ b/dev-resources/log4j.properties
@@ -1,8 +1,8 @@
 # Root logger option
-log4j.rootLogger=ERROR, stdout
+log4j.rootLogger=INFO, file
  
 # Direct log messages to stdout
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.Target=System.out
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n
\ No newline at end of file
+log4j.appender.file=org.apache.log4j.FileAppender
+log4j.appender.file.File=./logs/kafka.log
+log4j.appender.file.layout=org.apache.log4j.PatternLayout
+log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n
\ No newline at end of file
diff --git a/test/clj_kafka/test/consumer.clj b/test/clj_kafka/test/consumer.clj
index 7673dda..d4790e8 100644
--- a/test/clj_kafka/test/consumer.clj
+++ b/test/clj_kafka/test/consumer.clj
@@ -23,13 +23,11 @@
                                       "auto.commit.enable" "false"})]
         zk/shutdown
         (send-message p "test" "Hello, world")
-        (let [msgs (zk/messages c ["test"])
-              msg (first msgs)]
-          (let [{:keys [topic offset partition key value]} msg]
-            (is (= "test" topic))
-            (is (= 0 offset))
-            (is (= 0 partition))
-            (is (= "Hello, world" (String. value "UTF-8")))))))))
+        (let [{:keys [topic offset partition key value]} (first (zk/messages c ["test"]))]
+          (is (= "test" topic))
+          (is (= 0 offset))
+          (is (= 0 partition))
+          (is (= "Hello, world" (String. value "UTF-8"))))))))
 
 
 (deftest test-simple-consumer
diff --git a/test/clj_kafka/test/utils.clj b/test/clj_kafka/test/utils.clj
index d6a868c..7f1b8a5 100644
--- a/test/clj_kafka/test/utils.clj
+++ b/test/clj_kafka/test/utils.clj
@@ -28,7 +28,7 @@
                      "zookeeper.connect" "127.0.0.1:2182"
                      "enable.zookeeper" "true"
                      "log.flush.interval.messages" "1"
-                     "auto.create.topics.enabled" "true"
+                     "auto.create.topics.enable" "true"
                      "log.dir" (.getAbsolutePath (file (tmp-dir "kafka-log")))}]
     (KafkaServer. (KafkaConfig. (as-properties (assoc base-config "port" (str kafka-port))))
                   system-time)))