tuplejump / embedded-kafka

Embedded Kafka for testing and quick prototyping.

GitHub
Version Matrix

Embedded KafkaBuild Status

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

Features

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

Roadmap

  • 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

Documentation

Markdown Badge

Create badge

×
Markdown:
[![embedded-kafka Scala version support](https://index.scala-lang.org/tuplejump/embedded-kafka/embedded-kafka/latest-by-scala-version.svg)](https://index.scala-lang.org/tuplejump/embedded-kafka/embedded-kafka)
libraryDependencies += "com.tuplejump" %% "embedded-kafka" % "0.0.6"
Ammonite REPL 
import $ivy.`com.tuplejump::embedded-kafka:0.0.6`
<dependency>
  <groupId>com.tuplejump</groupId>
  <artifactId>embedded-kafka_2.11</artifactId>
  <version>0.0.6</version>
</dependency>
compile group: 'com.tuplejump', name: 'embedded-kafka_2.11', version: '0.0.6'
Mill build tool 
ivy"com.tuplejump::embedded-kafka:0.0.6"
Try online with Scastie
Try on Scastie

Statistics

Contributors

License

10 Dependencies

Java Dependencies