From f997dcfcb0ccb64cdec4391518ada6c1a5590005 Mon Sep 17 00:00:00 2001 From: Paul Ingles Date: Mon, 10 Jun 2013 15:07:33 +0100 Subject: [PATCH] rename :zookeeper-connect in to-clojure to :connect - it is the details to connect directly to the broker --- src/clj_kafka/core.clj | 2 +- test/clj_kafka/test/consumer/simple.clj | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/clj_kafka/core.clj b/src/clj_kafka/core.clj index e1bec01..5420256 100644 --- a/src/clj_kafka/core.clj +++ b/src/clj_kafka/core.clj @@ -40,7 +40,7 @@ Broker (to-clojure [x] - {:zookeeper-connect (.getZkString x) + {:connect (.getConnectionString x) :host (.host x) :port (.port x) :broker-id (.id x)}) diff --git a/test/clj_kafka/test/consumer/simple.clj b/test/clj_kafka/test/consumer/simple.clj index 3691ba5..0482f45 100644 --- a/test/clj_kafka/test/consumer/simple.clj +++ b/test/clj_kafka/test/consumer/simple.clj @@ -13,15 +13,15 @@ (expect count 1 first {:topic "test", :partition-metadata [{:partition-id 0, - :leader {:zookeeper-connect "localhost:9999", + :leader {:connect "localhost:9999", :host "localhost", :port 9999 :broker-id 0}, - :replicas [{:zookeeper-connect "localhost:9999", + :replicas [{:connect "localhost:9999", :host "localhost", :port 9999 :broker-id 0}], - :in-sync-replicas [{:zookeeper-connect "localhost:9999", + :in-sync-replicas [{:connect "localhost:9999", :host "localhost", :port 9999 :broker-id 0}],