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

fix hanging param from merge

Browse source
This commit is contained in:
Paul Lam 2013-06-07 16:36:42 +01:00
parent 20683d7e18
commit cd525fa6bd
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/producer.clj
View file

@ -28,7 +28,7 @@
(defn send-message
[^Producer producer ^String topic value]
(.send producer ^KeyedMessage (keyed-message topic (message-payload value)))))
(.send producer ^KeyedMessage (keyed-message topic (message-payload value))))
(defn brokers
"Get brokers from zookeeper"