Class | Description |
---|---|
ProducerPerformance | |
ThroughputThrottler |
This class helps producers throttle throughput.
|
VerifiableConsumer |
Command line consumer designed for system testing.
|
VerifiableConsumer.RecordData | |
VerifiableConsumer.RecordsConsumed | |
VerifiableLog4jAppender |
Primarily intended for use with system testing, this appender produces message
to Kafka on each "append" request.
|
VerifiableProducer |
Primarily intended for use with system testing, this producer prints metadata
in the form of JSON to stdout on each "send" request.
|