Uses of Class
org.apache.pulsar.client.api.transaction.TxnID
-
Uses of TxnID in org.apache.pulsar.client.api.transaction
Modifier and TypeMethodDescriptionTransaction.getTxnID()
Get TxnID of the transaction.TransactionCoordinatorClient.newTransaction()
Create a new transaction.TransactionCoordinatorClient.newTransaction
(long timeout, TimeUnit unit) Create a new transaction.Modifier and TypeMethodDescriptionTransactionBufferClient.abortTxnOnSubscription
(String topic, String subscription, long txnIdMostBits, long txnIdLeastBits, long lowWaterMark) Abort the transaction associated with the topic subscription.TransactionBufferClient.abortTxnOnTopic
(String topic, long txnIdMostBits, long txnIdLeastBits, long lowWaterMark) Abort the transaction associated with the topic.TransactionBufferClient.commitTxnOnSubscription
(String topic, String subscription, long txnIdMostBits, long txnIdLeastBits, long lowWaterMark) Commit the transaction associated with the topic subscription.TransactionBufferClient.commitTxnOnTopic
(String topic, long txnIdMostBits, long txnIdLeastBits, long lowWaterMark) Commit the transaction associated with the topic.TransactionCoordinatorClient.newTransactionAsync()
Create a new transaction asynchronously.TransactionCoordinatorClient.newTransactionAsync
(long timeout, TimeUnit unit) Create a new transaction asynchronously.Modifier and TypeMethodDescriptionvoid
Abort txn.TransactionCoordinatorClient.abortAsync
(TxnID txnID) Abort txn asynchronously.void
TransactionCoordinatorClient.addPublishPartitionToTxn
(TxnID txnID, List<String> partitions) Add publish partition to txn.TransactionCoordinatorClient.addPublishPartitionToTxnAsync
(TxnID txnID, List<String> partitions) Add publish partition to txn asynchronously.void
TransactionCoordinatorClient.addSubscriptionToTxn
(TxnID txnID, String topic, String subscription) Add ack subscription to txn.TransactionCoordinatorClient.addSubscriptionToTxnAsync
(TxnID txnID, String topic, String subscription) Add ack subscription to txn asynchronously.void
Commit txn.TransactionCoordinatorClient.commitAsync
(TxnID txnID) Commit txn asynchronously.