Embedded Kafka for demos, testing and quick prototyping. Much is taken right from the Apache Spark Streaming Kafka test files.
This is just the initial commit, more to come including code improvements, configuration improvements/additions.
- 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
- Improved and updated consumers
- Validation
- Additional and improved configuration
- Documentation
- And much more
Not pushed to sonatype yet, so for now you do need to build and publish to your local ivy repo:
sbt test
sbt it:test
sbt publish-local # binaries
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 both Scala versions by starting sbt then running these or other SBT tasks:
+ publish-local
+ test