public class ProducerConsumerTracker
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ProducerConsumerTracker.PerPartitionConsumptionInfo |
Constructor and Description |
---|
ProducerConsumerTracker() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<org.apache.kafka.common.TopicPartition,ProducerConsumerTracker.PerPartitionConsumptionInfo> |
getConsumptionInfo() |
long |
getNumberOfConsumedMessages() |
long |
getNumberOfMessagesToBeConsumed() |
long |
getNumberOfProducedMessages() |
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Map<java.lang.Long,java.lang.Long>> |
getProducerTimestampOffsetMap() |
long |
recordConsumedMessageBatch(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)
Records a batch of consumed messages and validates that it is in either the tracker
or the outstandingMessages set.
|
void |
recordOutstandingMessage(java.lang.String msg)
Records an enqueued message.
|
long |
recordProducedMessage(java.lang.String msg,
org.apache.kafka.clients.producer.RecordMetadata metadata)
Records a successfully produced message.
|
void |
removeOutstandingMessage(java.lang.String msg)
Removes an enqueued message.
|
java.lang.String |
status(boolean printPartitionCounts) |
public long recordProducedMessage(java.lang.String msg, org.apache.kafka.clients.producer.RecordMetadata metadata)
public long recordConsumedMessageBatch(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)
public void recordOutstandingMessage(java.lang.String msg)
public void removeOutstandingMessage(java.lang.String msg)
public long getNumberOfProducedMessages()
public long getNumberOfMessagesToBeConsumed()
public long getNumberOfConsumedMessages()
public java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Map<java.lang.Long,java.lang.Long>> getProducerTimestampOffsetMap()
public java.util.Map<org.apache.kafka.common.TopicPartition,ProducerConsumerTracker.PerPartitionConsumptionInfo> getConsumptionInfo()
public java.lang.String status(boolean printPartitionCounts)