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

Add type annotations for producer

Browse source
This commit is contained in:
Paul Bergeron 2013-04-08 16:21:27 -07:00
parent 3ce92430bb
commit 787897402b
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/clj_kafka/producer.clj
View file

@ -9,19 +9,19 @@
serializer.class : default is kafka.serializer.DefaultEncoder
zk.connect : Zookeeper connection. e.g. localhost:2181 "
[m]
(Producer. (ProducerConfig. (as-properties m))))
^Producer (Producer. (ProducerConfig. (as-properties m))))
(defn message
"Creates a message with the specified payload.
payload : bytes for the message payload. e.g. (.getBytes \"hello, world\")"
[payload]
[^:bytes payload]
(Message. payload))
(defn send-messages
"Sends a message.
topic : a string
msgs : a single message, or sequence of messages to send"
[producer topic msgs]
[^Producer producer ^String topic msgs]
(.send producer (ProducerData. topic msgs)))