test-kafka

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.

Usage

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"))

License

Copyright © 2014 Brian Schroeder

Distributed under the MIT License.

Copyright © 2013 Paul Ingles

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