Kafka:Sarama、幂等性和transactional.id
Shopify/sarama是否提供类似于transactional.idJVM API的选项?
该库支持幂等(Config.Producer.Idemponent,类似于enable.idempotence),但我不明白如何在没有transactional.id.
如果我错了,请纠正我,Sarama 中缺少有关这些选项的文档。但是根据 JVM 文档,没有标识符的幂等性将受到单个生产者会话的限制。换句话说,当生产者失败并重新启动时,我们将失去保证。
我在源代码和一些测试(例如)中找到了相关属性,但不明白如何在外部使用它们。