Simple helper assertions.
A utility trait for integration testing.
Implements a simple standalone ZooKeeperServer.
The KafkaConsumer is a very simple consumer of a single Kafka topic.
Simple producer using string encoder and default partitioner.
Simple producer for an Akka Actor using string encoder and default partitioner.
Simple actor with a Kafka consumer to report the latest message count in a Kafka Topic.