@Internal public class KafkaPartitionSplitState extends KafkaPartitionSplit
COMMITTED_OFFSET, EARLIEST_OFFSET, LATEST_OFFSET, NO_STOPPING_OFFSET, VALID_STARTING_OFFSET_MARKERS, VALID_STOPPING_OFFSET_MARKERS
Constructor and Description |
---|
KafkaPartitionSplitState(KafkaPartitionSplit partitionSplit) |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentOffset() |
void |
setCurrentOffset(long currentOffset) |
KafkaPartitionSplit |
toKafkaPartitionSplit()
Use the current offset as the starting offset to create a new KafkaPartitionSplit.
|
equals, getPartition, getStartingOffset, getStoppingOffset, getTopic, getTopicPartition, hashCode, splitId, toSplitId, toString
public KafkaPartitionSplitState(KafkaPartitionSplit partitionSplit)
public long getCurrentOffset()
public void setCurrentOffset(long currentOffset)
public KafkaPartitionSplit toKafkaPartitionSplit()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.