Version 0.2.0 of Kafka for Junit has been released. It features a couple of small improvements to the code and documentation, as well as the addition of ExternalKafkaCluster, which is an abstraction that allows you to use the same convenient accessor interfaces that you are already familiar with when interacting with embedded Kafka clusters, against external Kafka clusters.
Changelog
See the changelog on GitHub.
Features
- #10: Provide the means to use accessors against an external Kafka cluster
- #11: Provide a builder for java.lang.Properties to retain the fluent API when provisioning Connect workers
- #12: Remove Exception types from accessor interfaces
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.2.0</version>
</dependency>
Gradle
compile 'net.mguenther.kafka:kafka-junit:0.2.0'
