Kafka-Python如何手动提交?

问题描述 投票:0回答:1

我对Kafka很新,刚开始使用Python,所以原谅我的错误条款,我会试着解释一下我的要点。

我有一个Kafka队列,我的主题是实用的。现在,这些主题将包含订单列表,并将由消费者选择进行处理。我的要求是,如果一个主题中有多个订单,后续订单只应在前一个订单成功时处理,如果订单失败我希望重试。此外,还可以手动处理多个主题的订单。因此,在阅读文档的同时,我讲述了提供补偿的概念,我不确定这是否会对我有所帮助,我无法将它们拼凑在一起。有人可以帮我弄这个吗?

python-3.x apache-kafka kafka-consumer-api kafka-python
1个回答
0
投票

这种逻辑是您必须在消费者的kafka之外解决的问题。 Kafka提供了一些场景:至少一次,至少一次,完全一次

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

但似乎你有一个同步订单处理系统,你将失去使用Kafka的一些好处。您可以尝试At-Most-Once,如果失败,则将其推回主题。

© www.soinside.com 2019 - 2024. All rights reserved.