Package io.eventuate.messaging.kafka.basic.consumer

Class OffsetTracker

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.OffsetTracker

public class OffsetTracker
extends Object

Keeps track of message offsets that are (a) being processed and (b) have been processed and can be committed

Constructor Summary

Constructors

Constructor	Description
OffsetTracker()

Method Summary

Modifier and Type	Method	Description
Map<org.apache.kafka.common.TopicPartition,Set<Long>>	getPending()
void	noteOffsetsCommitted(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit)
Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>	offsetsToCommit()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

OffsetTracker

public OffsetTracker()

Method Details

toString

public String toString()

Overrides:

toString in class Object

offsetsToCommit

public Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit()

noteOffsetsCommitted

public void noteOffsetsCommitted(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsetsToCommit)

getPending

public Map<org.apache.kafka.common.TopicPartition,Set<Long>> getPending()