Consumer that dumps messages to standard out.
Performance test for the full zookeeper consumer
This class records the average end to end latency for a single message to travel through Kafka
A utility that retrieve the offset of broker partitions in ZK and prints to an output file in the following format:
A utility that updates the offset of broker partitions in ZK.
The mirror maker has the following architecture: - There are N mirror maker thread shares one ZookeeperConsumerConnector and each owns a Kafka stream.
For verifying the consistency among replicas.
Performance test for the simple consumer
Command line program to dump out messages to standard out using the simple consumer
A utility that merges the state change logs (possibly obtained from different brokers and over multiple days).
A utility that updates the offset of every broker partition to the offset of earliest or latest log segment file, in ZK.
ZooKeeper 3.
Load test for the producer