Class TransactionPolicy

java.lang.Object
org.apache.pulsar.client.api.v5.config.TransactionPolicy

public final class TransactionPolicy extends Object
Transaction configuration for the Pulsar client.

Construct via builder().

  • Method Details

    • timeout

      public Duration timeout()
      Returns:
      transaction timeout — if the transaction is not committed or aborted within this duration, the broker automatically aborts it
    • builder

      public static TransactionPolicy.Builder builder()
      Returns:
      a new builder for constructing a TransactionPolicy