TopicPartitionOffsets (eventuate-messaging-kafka-basic-consumer 0.20.0.RELEASE API)

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.TopicPartitionOffsets

public class TopicPartitionOffsets extends Object

Tracks the offsets for a TopicPartition that are being processed or have been processed

Constructor Summary

Constructors

Constructor

Description

TopicPartitionOffsets()
Method Summary

Modifier and Type

Method

Description

Set<Long>

getPending()

void

noteOffsetCommitted(long offset)

void

noteProcessed(long offset)

void

noteUnprocessed(long offset)

String

toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- TopicPartitionOffsets
  
  public TopicPartitionOffsets()
Method Details
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object
- noteUnprocessed
  
  public void noteUnprocessed(long offset)
- noteProcessed
  
  public void noteProcessed(long offset)
- noteOffsetCommitted
  
  public void noteOffsetCommitted(long offset)
- getPending
  
  public Set<Long> getPending()