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

use create-all when creating the node

Browse source
This commit is contained in:
Paul Ingles 2014-05-09 17:44:57 +01:00
parent 031b80f05d
commit 3cf86987bb
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/clj_kafka/zk.clj
View file

@ -82,4 +82,4 @@
(zk/delete z path)
(if-let [{:keys [version] :as m} (zk/exists z path)]
(zk/set-data z path (.getBytes (str offset)) version)
(zk/create z path :persistent? true :data (.getBytes (str offset))))))))
(zk/create-all z path :persistent? true :data (.getBytes (str offset))))))))