public class TopicPartitionInitialOffset
extends java.lang.Object
null - do nothing;0) - seek to the absolute offset within the partition;
consumer.seekToEnd() + initialOffset.start()ed.| Constructor and Description |
|---|
TopicPartitionInitialOffset(java.lang.String topic,
int partition) |
TopicPartitionInitialOffset(java.lang.String topic,
int partition,
java.lang.Long initialOffset) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.lang.Long |
initialOffset() |
int |
partition() |
java.lang.String |
topic() |
org.apache.kafka.common.TopicPartition |
topicPartition() |
java.lang.String |
toString() |
public TopicPartitionInitialOffset(java.lang.String topic,
int partition)
public TopicPartitionInitialOffset(java.lang.String topic,
int partition,
java.lang.Long initialOffset)
public org.apache.kafka.common.TopicPartition topicPartition()
public int partition()
public java.lang.String topic()
public java.lang.Long initialOffset()
public boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Object