apache-kafka - kafka 幂等和事务性生产者设置之间的区别？

Question

在设置 kafka 生产者以使用幂等行为和事务行为时:

我知道对于幂等性我们设置:enable.idempotence=true并且通过在我们的生产者上更改这一标志，我们可以保证事件交付一次？

对于交易，我们必须更进一步并设置transaction.id=<some value>但是通过设置这个值，它也将幂等性设置为真？

此外，通过将上述一项或两项设置为 true，生产者还将设置 acks=all。

有了上述内容，我是否可以通过简单地更改启用幂等性设置来添加“恰好一次交付”？如果我想更进一步并启用事务支持，在消费者方面，我只需要更改他们的设置，isolation.level=read_committed ?此图像是否反射(reflect)了如何设置 producer在 EOS 方面？

Answer 1

是的，你理解了主要概念。

通过启用幂等性，生产者会自动设置 acks至 all并保证在 Producer 实例的生命周期内传递消息。

通过启用事务，生产者会自动启用幂等性(和 acks=all )。事务允许对生产请求和偏移提交进行分组，并确保向 Kafka 提交全部或全部内容。

使用事务时，您可以通过设置 isolation.level 来配置消费者是否应该只看到来自已提交事务的记录。至 read_committed ，否则默认情况下他们会看到所有记录，包括来自丢弃交易的记录。