我有一个场景,需要向通知服务调用api,通知服务将向用户发送电子邮件。 根据主题显示的消息,我需要使用并调用api。 但是,如果消费者由于消费者的至少一次配置的性质而在两者之间失败,则很难避免重复处理。 抱歉,我是新手。我试图找到许多博客,但大多数都使用卡夫卡的新版本,但在我们的infra中,他们仍然使用旧版本。 想知道我们如何实现这种行为? 我之前提到的链接: If exactly-once semantics are impossible, what theoretical constraint is Kafka relaxing?
我还看到了一些文档,其中提到将处理结果和偏移量存储到同一个存储中。但我的场景是api调用让我们想象一下,如果消费者在提交偏移量之前调用api并在两者之间死亡,那么下一次轮询将获得该消息和调用api。这样,电子邮件将被发送两次。
感谢您的帮助。