public class VerifiableConsumer
extends java.lang.Object
implements java.io.Closeable, org.apache.kafka.clients.consumer.OffsetCommitCallback, org.apache.kafka.clients.consumer.ConsumerRebalanceListener
ConsumerRebalanceListener.onPartitionsRevoked(Collection)
.
See VerifiableConsumer.PartitionsRevoked
ConsumerRebalanceListener.onPartitionsAssigned(Collection)
See VerifiableConsumer.PartitionsAssigned
.KafkaConsumer.poll(long)
.
See VerifiableConsumer.RecordsConsumed
.VerifiableConsumer.RecordData
.VerifiableConsumer.OffsetsCommitted
KafkaConsumer.close()
.
See VerifiableConsumer.ShutdownComplete
.Modifier and Type | Class and Description |
---|---|
static class |
VerifiableConsumer.RecordData |
static class |
VerifiableConsumer.RecordsConsumed |
Constructor and Description |
---|
VerifiableConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> consumer,
java.io.PrintStream out,
java.lang.String topic,
int maxMessages,
boolean useAutoCommit,
boolean useAsyncCommit,
boolean verbose) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commitSync(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets) |
static VerifiableConsumer |
createFromArgs(net.sourceforge.argparse4j.inf.ArgumentParser parser,
java.lang.String[] args) |
static void |
main(java.lang.String[] args) |
void |
onComplete(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
java.lang.Exception exception) |
void |
onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions) |
void |
onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions) |
void |
run() |
public VerifiableConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> consumer, java.io.PrintStream out, java.lang.String topic, int maxMessages, boolean useAutoCommit, boolean useAsyncCommit, boolean verbose)
public void onComplete(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, java.lang.Exception exception)
onComplete
in interface org.apache.kafka.clients.consumer.OffsetCommitCallback
public void onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
onPartitionsAssigned
in interface org.apache.kafka.clients.consumer.ConsumerRebalanceListener
public void onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
onPartitionsRevoked
in interface org.apache.kafka.clients.consumer.ConsumerRebalanceListener
public void commitSync(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
public void run()
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public static VerifiableConsumer createFromArgs(net.sourceforge.argparse4j.inf.ArgumentParser parser, java.lang.String[] args) throws net.sourceforge.argparse4j.inf.ArgumentParserException
net.sourceforge.argparse4j.inf.ArgumentParserException
public static void main(java.lang.String[] args)