public class PulsarPartitionSplitState extends Object
Constructor and Description |
---|
PulsarPartitionSplitState(PulsarPartitionSplit split) |
Modifier and Type | Method and Description |
---|---|
org.apache.pulsar.client.api.MessageId |
getLatestConsumedId() |
TopicPartition |
getPartition() |
org.apache.pulsar.client.api.transaction.TxnID |
getUncommittedTransactionId() |
void |
setLatestConsumedId(org.apache.pulsar.client.api.MessageId latestConsumedId) |
void |
setUncommittedTransactionId(org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId) |
PulsarPartitionSplit |
toPulsarPartitionSplit()
Create a partition split which contains the latest consumed message id as the start position.
|
public PulsarPartitionSplitState(PulsarPartitionSplit split)
public PulsarPartitionSplit toPulsarPartitionSplit()
public TopicPartition getPartition()
@Nullable public org.apache.pulsar.client.api.transaction.TxnID getUncommittedTransactionId()
public void setUncommittedTransactionId(@Nullable org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId)
@Nullable public org.apache.pulsar.client.api.MessageId getLatestConsumedId()
public void setLatestConsumedId(@Nullable org.apache.pulsar.client.api.MessageId latestConsumedId)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.