send!
(commit)0.1.3
=> (def p (g/producer (get-in config [:kafka :producer])))
;; send a couple of messages to topics: "foos" and "bars"
=> (g/send! p "foos" "{:answer 42}")
=> (g/send! p "bars" "{:answer 42}")
=> (g/close p)
0.1.3
grete/producer returned a map of {:producer .. :topic ..}
:
=> (def p (g/producer "foos" (get-in config [:kafka :producer])))
=> (g/send! p "{:answer 42}")
=> (g/send! p "{:answer 42}")
=> (g/close p)
Can you improve this documentation? These fine people already did:
anatoly & AnatolyEdit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close