TopicOffset.latest constructor

TopicOffset.latest(
  1. String topicName,
  2. int partitionId
)

Creates pseudo-offset which refers to latest offset in this topic and partition.

Implementation

TopicOffset.latest(this.topicName, this.partitionId) : offset = -1;