Kafka:Sarama、幂等性和transactional.id

Shopify/sarama是否提供类似于transactional.idJVM API的选项?

该库支持幂等(Config.Producer.Idemponent,类似于enable.idempotence),但我不明白如何在没有transactional.id.

如果我错了,请纠正我,Sarama 中缺少有关这些选项的文档。但是根据 JVM 文档,没有标识符的幂等性将受到单个生产者会话的限制。换句话说,当生产者失败并重新启动时,我们将失去保证。

我在源代码和一些测试(例如)中找到了相关属性,但不明白如何在外部使用它们。

以上是Kafka:Sarama、幂等性和transactional.id的全部内容。
THE END
分享
二维码
< <上一篇
下一篇>>