Skip to content

Commit

Permalink
Revert "Revert "[improve][doc]Add introduction of transaction isolati…
Browse files Browse the repository at this point in the history
…on level in the txn-advanced-features.md (#712)""

This reverts commit 6ff9b3e.
  • Loading branch information
visortelle committed May 27, 2024
1 parent 6ff9b3e commit a1791e9
Showing 1 changed file with 24 additions and 1 deletion.
25 changes: 24 additions & 1 deletion docs/txn-advanced-features.md
Original file line number Diff line number Diff line change
Expand Up @@ -37,10 +37,33 @@ If you want to enable authentication with transactions, follow the steps below.

2. [Configure authentication](security-overview/#authentication) in a Pulsar client.

## Select transaction isolation level

To enhance the flexibility of Pulsar transactions, they support two distinct isolation levels:
- `READ_COMMITTED`(default): The consumer can only consume all transactional messages that have been committed.
- `READ_UNCOMMITTED`: The consumer can consume all messages, even transactional messages that have been aborted.

For different scenarios, they use different subscriptions and choose different isolation levels. One scenario might require transactions, while another might not. In general, not all subscriptions of the same topic require transaction guarantees. Some want low latency without the exact-once semantic guarantee (like a real-time monitoring system), and some must require the exactly-once guarantee (e.g., business processing systems).
Users can freely choose different isolation levels according to different scenarios.

Note that this is a subscription-level configuration, and all consumers under the same subscription must be configured with the same isolation level.

In this example, the consumer builder uses the `READ_UNCOMMITTED` isolation level.

```java
Consumer<String> consumer = client
.newConsumer(Schema.STRING)
.topic("persistent://my-tenant/my-namespace/my-topic")
.subscriptionName("my-subscription")
.subscriptionType(SubscriptionType.Shared)
.subscriptionIsolationLevel(SubscriptionIsolationLevel.READ_UNCOMMITTED) // Adding the isolation level configuration
.subscribe();
```

## Guarantee exactly-once semantics

If you want to guarantee exactly-once semantics with transactions, you can [enable message deduplication at the broker, namespace, or topic level](cookbooks-deduplication.md#enable-message-deduplication-at-namespace-or-topic-level).

## Related topics

- To get up quickly, see [Pulsar transactions - Get started](txn-use.md).
- To get up quickly, see [Pulsar transactions - Get started](txn-use.md).

0 comments on commit a1791e9

Please sign in to comment.