Why transactions?

随着流处理的兴起，对具有更强处理保证的流处理应用的需求也在增长。 例如，在金融行业，金融机构使用流处理引擎为用户处理借款和信贷。 这种类型的用例要求每条消息都只处理一次，无一例外。

换句话说，如果流处理应用程序消费消息 A 并将结果作为消息B (B = f(A))，那么恰好一次处理保证意味着当且仅当 B 被成功生产后 A 才能被标记为消费，反之亦然。

Pulsar 事务 API 加强了消息传递语义和流处理的处理保证。 它使流处理应用程序能够在一个原子操作中使用、处理和生成消息。 这意味着，事务中的一批消息可以从许多主题分区接收、生成和确认。 一个事务涉及的所有操作都作为整体成功或失败。

幂等生产者的局限性

在Pulsar中，最高级别的消息传递保证是使用 在单个分区上使用恰好一次语义，即每条消息只持久化一次，不会丢失和重复。 然而，这种解决办法有一些限制：

• 由于单调递增的序列ID，该方案仅适用于单个分区和单个生产者会话内（即生产一条消息），因此向一个或多个分区生产多条消息时没有原子性。

  在这种情况下，如果在产生和接收消息的过程中出现一些故障（例如，client/broker/bookie崩溃、网络故障等），消息会被重新处理和重新投递，这可能会导致数据丢失或数据重复：

• 消费者需要依赖更多的机制来确认（ack）消息一次。