与 Fs2-kafka 的交易

Question

我正在寻找一种使用生产者进行交易的方法，使用 fs2， 然而，当前的 TransactionalProducer 似乎是面向端到端工作流的场景，即消费-流程-生产。

但是，我们希望在我们只是向 kafka 生成消息的上下文中使用它。

有没有一种已知的方法可以使用 fs2-kafka 实现这一目标？我试图看看如何，但似乎不可能，也许我错过了什么？

编辑1

经过仔细检查，显然不支持该用例。但是我很好奇为什么？是出于特定原因，我在实施自己的解决方案时可能需要注意，还是只是因为没有特定原因而没有完成并且永远不会完成？如果有人能解释一下？

Answer 1

最终，事务生产者添加到enable.idempotence=true, acks=all 的唯一内容是消费者偏移量作为生成消息的一部分被提交。由于提交的偏移量意味着成功的生产，反之亦然，这允许消费-过程-生产流有效地处理消息一次（Confluent 可以说稍微延伸了恰好一次的术语），假设 process 步骤中的所有内容都是也是幂等的。