tuplejump / embedded-kafka   0.0.6

Apache License 2.0 GitHub

Embedded Kafka for testing and quick prototyping.

Scala versions: 2.11 2.10

Embedded KafkaBuild Status

Embedded Kafka for demos, testing and quick prototyping. Much is taken right from the Apache Spark Streaming Kafka test files.


  • Quick and easy prototyping, testing
  • Safe demos - not reliant on network
  • Compatible with Apache Kafka:,
  • Compatible with Scala 2.10 and 2.11
  • Embedded Zookeeper which starts automatically when starting Kafka
  • Simple Kafka consumer


  • Improved and updated consumers
  • Validation
  • Additional and improved configuration
  • Documentation
  • And much more

Scala Version

This project uses Scala 2.11 by default. To build against Scala 2.10 vs 2.11 run

sbt -Dscala.version=2.10.6 
sbt -Dscala.version=2.10.6 test
sbt -Dscala.version=2.10.6 publish-local

Cross Build

Cross build both Scala versions by starting sbt then running these or other SBT tasks:

+ publish-local
+ test