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

use threading macro to tidy consumer.zk/messages

Browse source
This commit is contained in:
Paul Ingles 2012-05-18 12:28:58 +01:00
parent f9574228db
commit 1fca1666ec
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/consumer/zk.clj
View file

@ -39,7 +39,7 @@
(let [[queue-seq queue-put] (pipe)] (let [[queue-seq queue-put] (pipe)]
(doseq [[topic streams] (.createMessageStreams consumer (topic-map topics))] (doseq [[topic streams] (.createMessageStreams consumer (topic-map topics))]
(future (doseq [msg (iterator-seq (.iterator (first streams)))] (future (doseq [msg (iterator-seq (.iterator (first streams)))]
(queue-put (assoc (to-clojure msg) :topic topic))))) (queue-put (-> msg to-clojure (assoc :topic topic))))))
queue-seq)) queue-seq))
(defn topics (defn topics