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

add number of consumer threads to zk consumer

Browse source
This commit is contained in:
Paul Ingles 2014-04-28 14:12:41 +01:00
parent 8acfb69df6
commit 52032432b9
2 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
project.clj
View file

@ -1,4 +1,4 @@
(defproject clj-kafka/clj-kafka "0.2.1-0.8"
(defproject clj-kafka/clj-kafka "0.2.2-0.8"
:min-lein-version "2.0.0"
:dependencies [[org.clojure/clojure "1.5.1"]
[zookeeper-clj "0.9.3"]

5
src/clj_kafka/consumer/zk.clj
View file

@ -37,8 +37,9 @@
(defn messages
"Creates a sequence of KafkaMessage messages from the given topic. Consumes
messages from a single stream."
[^ConsumerConnector consumer topic]
[^ConsumerConnector consumer topic & {:keys [threads]
:or {threads 1}}]
(let [[_topic [stream & _]]
(first (.createMessageStreams consumer {topic (int 1)}))]
(first (.createMessageStreams consumer {topic (int threads)}))]
(map to-clojure
(lazy-iterate (.iterator ^KafkaStream stream)))))