kafka-embedded

Runs embedded, in-memory Apache Kafka and Apache ZooKeeper instances. Helpful for integration testing.

The code in this project was extracted from kafka-storm-starter to allow for easier reuse in other projects.

---

Table of Contents

• Features
• Requirements
• Usage
• Change log
• Contributing
• License

---

Features

With this project you can run in-memory instances of:

• Kafka -- see KafkaEmbedded
• ZooKeeper -- see ZooKeeperEmbedded
• A ready-to-use Kafka and ZooKeeper "cluster" -- see KafkaZooKeeperCluster

Requirements

• Java 7
• Scala 2.10

Usage

Build dependencies

This project is published via Sonatype.

• Snapshots are available in the Maven repository at https://oss.sonatype.org/content/repositories/snapshots
• Releases are available on Maven Central.

Example 1, using a snapshot:

// In build.sbt
resolvers ++= Seq("sonatype-snapshots" at "https://oss.sonatype.org/content/repositories/snapshots")

libraryDependencies ++= Seq("com.miguno" % "kafka_embedded_2.10" % "0.1.0-SNAPSHOT")

Example 2, using a release (note: no release has been published yet!):

// In build.sbt
libraryDependencies ++= Seq("com.miguno" % "kafka_embedded_2.10" % "0.1.0")

Examples

A full example of an integration test using in-memory instances of Kafka and ZooKeeper is available at KafkaZooKeeperClusterSpec.

Change log

See CHANGELOG.

Contributing to kafka-embedded

Code contributions, bug reports, feature requests etc. are all welcome.

If you are new to GitHub please read Contributing to a project for how to send patches and pull requests to kafka-embedded.

License

Copyright © 2014 Michael G. Noll

See LICENSE for licensing information.