Kafka JUnit Integration

net.mguenther.kafka » kafka-junit

Provides an embedded Kafka cluster consisting of Apache ZooKeeper, Apache Kafka Brokers and Kafka Connect workers in distributed mode along with a rich set of convenient accessors to interact with the embedded Kafka cluster.