yogsototh/clj-kafka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

add partitions fn to access partition/replica data

Browse source
This commit is contained in:
Paul Ingles 2014-05-07 17:49:06 +01:00
parent ddb0a77391
commit 308c76a864
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/clj_kafka/zk.clj
View file

@ -44,3 +44,14 @@
(with-resource [z (zk/connect (get m "zookeeper.connect"))]
zk/close
(zk/children z "/brokers/topics")))
(defn partitions
"Returns a map of partitions and replica ids. e.g. {\"1\" [0], \"0\" [0]}"
[m topic]
(with-resource [z (zk/connect (get m "zookeeper.connect"))]
zk/close
(-> (zk/data z (str "/brokers/topics/" topic))
:data
String.
read-str
(get "partitions"))))