Skip to content
/ test-kafka Public

An in-process Kafka and ZooKeeper runner for testing in Clojure

License

Notifications You must be signed in to change notification settings

bts/test-kafka

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

20 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

test-kafka Circle CI

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.

About

An in-process Kafka and ZooKeeper runner for testing in Clojure

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published