Kafka-Python如何手动提交？

Question

我是Kafka的新手，刚刚开始使用Python，所以请原谅我的错误术语，我将尝试解释我的要点。

我有一个Kafka队列，我的主题是实用化地生成的。现在，这些主题将包含一个订单列表，并将由消费者选择进行处理。我的要求是，如果一个主题中有多个订单，则仅当前一个订单成功时才应处理后续订单，如果订单失败，则希望重试。此外，还可以手动处理多个主题中的订单。因此，当我通读文档时，我发现了提交偏移量的概念，我不确定这是不是对我有帮助的东西，我不能把它们拼凑在一起。有人能帮我一下吗？

Answer 1

这个逻辑是你必须在消费者的kafka之外解决的问题。Kafka提供了一些场景:至多一次，至少一次，恰好一次

https://dzone.com/articles/kafka-clients-at-most-once-at-least-once-exactly-o

但是看起来你有一个同步的订单处理系统，你会失去使用Kafka的一些好处。您最多可以尝试一次，如果失败，您可以将其推回到主题中。