C K L M N O P R S T V 

C

close() - Method in class org.apache.kafka.tools.VerifiableConsumer
 
close() - Method in class org.apache.kafka.tools.VerifiableProducer
Close the producer to flush any remaining messages.
commitSync(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.tools.VerifiableConsumer
 
count() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordsConsumed
 
createFromArgs(ArgumentParser, String[]) - Static method in class org.apache.kafka.tools.VerifiableConsumer
 
createFromArgs(String[]) - Static method in class org.apache.kafka.tools.VerifiableLog4jAppender
Construct a VerifiableLog4jAppender object from command-line arguments.
createFromArgs(String[]) - Static method in class org.apache.kafka.tools.VerifiableProducer
Construct a VerifiableProducer object from command-line arguments.

K

key() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 

L

loadProps(String) - Static method in class org.apache.kafka.tools.VerifiableLog4jAppender
Read a properties file from the given path
loadProps(String) - Static method in class org.apache.kafka.tools.VerifiableProducer
Read a properties file from the given path

M

main(String[]) - Static method in class org.apache.kafka.tools.ProducerPerformance
 
main(String[]) - Static method in class org.apache.kafka.tools.VerifiableConsumer
 
main(String[]) - Static method in class org.apache.kafka.tools.VerifiableLog4jAppender
 
main(String[]) - Static method in class org.apache.kafka.tools.VerifiableProducer
 

N

name() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 
name() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordsConsumed
 

O

offset() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 
onComplete(Map<TopicPartition, OffsetAndMetadata>, Exception) - Method in class org.apache.kafka.tools.VerifiableConsumer
 
onPartitionsAssigned(Collection<TopicPartition>) - Method in class org.apache.kafka.tools.VerifiableConsumer
 
onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.apache.kafka.tools.VerifiableConsumer
 
org.apache.kafka.tools - package org.apache.kafka.tools
 

P

partition() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 
partitions() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordsConsumed
 
ProducerPerformance - Class in org.apache.kafka.tools
 
ProducerPerformance() - Constructor for class org.apache.kafka.tools.ProducerPerformance
 

R

run() - Method in class org.apache.kafka.tools.VerifiableConsumer
 

S

send(String, String) - Method in class org.apache.kafka.tools.VerifiableProducer
Produce a message with given key and value.
shouldThrottle(long, long) - Method in class org.apache.kafka.tools.ThroughputThrottler
 

T

throttle() - Method in class org.apache.kafka.tools.ThroughputThrottler
Occasionally blocks for small amounts of time to achieve targetThroughput.
ThroughputThrottler - Class in org.apache.kafka.tools
This class helps producers throttle throughput.
ThroughputThrottler(long, long) - Constructor for class org.apache.kafka.tools.ThroughputThrottler
 
topic() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 

V

value() - Method in class org.apache.kafka.tools.VerifiableConsumer.RecordData
 
VerifiableConsumer - Class in org.apache.kafka.tools
Command line consumer designed for system testing.
VerifiableConsumer(KafkaConsumer<String, String>, PrintStream, String, int, boolean, boolean, boolean) - Constructor for class org.apache.kafka.tools.VerifiableConsumer
 
VerifiableConsumer.RecordData - Class in org.apache.kafka.tools
 
VerifiableConsumer.RecordData(ConsumerRecord<String, String>) - Constructor for class org.apache.kafka.tools.VerifiableConsumer.RecordData
 
VerifiableConsumer.RecordsConsumed - Class in org.apache.kafka.tools
 
VerifiableConsumer.RecordsConsumed(long, List<VerifiableConsumer.RecordSetSummary>) - Constructor for class org.apache.kafka.tools.VerifiableConsumer.RecordsConsumed
 
VerifiableLog4jAppender - Class in org.apache.kafka.tools
Primarily intended for use with system testing, this appender produces message to Kafka on each "append" request.
VerifiableLog4jAppender(Properties, int) - Constructor for class org.apache.kafka.tools.VerifiableLog4jAppender
 
VerifiableProducer - Class in org.apache.kafka.tools
Primarily intended for use with system testing, this producer prints metadata in the form of JSON to stdout on each "send" request.
VerifiableProducer(Properties, String, int, int) - Constructor for class org.apache.kafka.tools.VerifiableProducer
 
C K L M N O P R S T V