Class ConsumerLogOffsets
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
-
- All Implemented Interfaces:
Comparable<ConsumerLogOffsets>
public class ConsumerLogOffsets extends Object implements Comparable<ConsumerLogOffsets>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description OffsetAndTimestamp
committedOffset()
ConsumerLogOffsets
committedOffset(OffsetAndTimestamp committedOffset)
int
compareTo(ConsumerLogOffsets that)
OffsetAndTimestamp
consumedOffset()
ConsumerLogOffsets
consumedOffset(OffsetAndTimestamp consumedOffset)
boolean
equals(Object o)
int
hashCode()
Long
lag()
Long
logEndOffset()
ConsumerLogOffsets
logEndOffset(Long logEndOffset)
Long
logStartOffset()
ConsumerLogOffsets
logStartOffset(Long logStartOffset)
org.apache.kafka.common.TopicPartition
topicPartition()
String
toString()
-
-
-
Method Detail
-
topicPartition
public org.apache.kafka.common.TopicPartition topicPartition()
-
logEndOffset
public Long logEndOffset()
-
logStartOffset
public Long logStartOffset()
-
lag
public Long lag()
-
consumedOffset
public OffsetAndTimestamp consumedOffset()
-
committedOffset
public OffsetAndTimestamp committedOffset()
-
consumedOffset
public ConsumerLogOffsets consumedOffset(OffsetAndTimestamp consumedOffset)
-
committedOffset
public ConsumerLogOffsets committedOffset(OffsetAndTimestamp committedOffset)
-
logEndOffset
public ConsumerLogOffsets logEndOffset(Long logEndOffset)
-
logStartOffset
public ConsumerLogOffsets logStartOffset(Long logStartOffset)
-
compareTo
public int compareTo(ConsumerLogOffsets that)
- Specified by:
compareTo
in interfaceComparable<ConsumerLogOffsets>
-
-