Liking cljdoc? Tell your friends :D


A Clojure wrapper around the Apache Kafka APIs


Add the dependency to your project.clj:

[com.bioniccletus/metamorph "0.1.0"]

Send a message to a Kafka broker with zookeeper broker discovery:

This assumes you have an instance of zookeeper running on localhost:2181

(use com.bioniccletus.metamorph.core)

;; Register producer config
  {:zk.connect       ""
   :serializer.class "kafka.serializer.StringEncoder"})

;; Post a message to the "test" topic with a body of "hello, kafka"
(with-producer [p :my-producer]
  (send-message p "test" "hello, kafka"))


Copyright © 2012

Distributed under the Eclipse Public License, the same as Clojure.

Can you improve this documentation?Edit on GitHub

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close