@Internal public final class PulsarTransactionUtils extends Object
Transaction
didn't
provide a id method until 2.8.1. We have to add this util for acquiring the TxnID
for
compatible consideration.
TODO Remove this hack after pulsar 2.8.1 release.
Modifier and Type | Method and Description |
---|---|
static org.apache.pulsar.client.api.transaction.TxnID |
getId(org.apache.pulsar.client.api.transaction.Transaction transaction) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.