JavaScript is disabled on your browser.
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes