The first version of Kafka for JUnit has been released. It features a customizable embedded Kafka broker setup with Kafka Connect and a rich set of convenient accessors to interact with the cluster.
Changelog
See the changelog on GitHub.
Features
- #1: Add support for writing Kafka records transactionally
- #2: Add a compatibility matrix to the README
- #3: Add a user guide with examples on how to use kafka-junit
- #5: Simplify type parameterization for ReadKeyValues and ObserveKeyValues
- #7: Add a filtering mechanism on keys and values
- #8: Refine and stabilize implementation of 0.1.0
Bugfixes:
None.
Get it
You can obtain the binaries from Maven central or include the dependency using the following Maven coordinates in your build.
Maven
<dependency>
<groupId>net.mguenther.kafka</groupId>
<artifactId>kafka-junit</artifactId>
<version>0.1.0</version>
</dependency>
Gradle
compile 'net.mguenther.kafka:kafka-junit:0.1.0'
