An in-process Kafka and ZooKeeper runner for testing in Clojure. Adapted from clj-kafka's integration tests.
The current version depends on Kafka 0.8.2 or higher. If you require compatibility with Kafka 0.8.0 or 0.8.1, use test-kafka 0.1.0.
Install with Leiningen:
[test-kafka "0.2.0"]Then:
(require 'test-kafka)
(test-kafka/with-broker [kafka-port zk-port topic-name]
(comment "interact with kafka"))
(test-kafka/with-zk [port]
(comment "interact with zookeeper"))Copyright © 2014 Brian Schroeder
Distributed under the MIT License.
Copyright © 2013 Paul Ingles
Distributed under the Eclipse Public License, the same as Clojure.