This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No need to stand up an external kafka cluster!
This library wraps Apache Kafka's KafkaServerStartable class and allows you to easily create and run tests against one or more "real" kafka brokers. No longer do you need to setup and coordinate with an external kafka cluster for your tests! The library transparently supports running a single or multi-broker cluster. Running a multi-broker cluster allows you to validate how your software reacts under various error scenarios, such as when one or more brokers become unavailable.
Please review Kafka-JUnit4 Readme for usage instructions with JUnit4.
Please review Kafka-JUnit5 Readme for usage instructions with JUnit5.
For use cases where you want to embed Kafka broker/cluster within your existing software, you can make use of the core package directly. Please review Kafka-JUnit-Core Readme for usage instructions.
Found a bug? Think you've got an awesome feature you want to add? We welcome contributions!
Make sure that you rebase your branch off of master before opening a new pull request. We might also ask you to rebase it if master changes after you open your pull request.
We love contributions, but it's important that your pull request adhere to some of the standards we maintain in this repository.
We use checkstyle aggressively on source and tests, our config is located under the 'script' folder and can be imported into your IDE of choice.
Steps for proper release: - Update release version:
mvn versions:set -DnewVersion=X.Y.Z- Validate and then commit version:
mvn versions:commit- Update CHANGELOG and README files. - Merge to master. - Deploy to Maven Central:
mvn clean deploy -P release-kafka-junit- Create release on Github project.
BSD 3-Clause View License.