如何使用kafka处理以下问题

Question

假设我有以下情况

producer sends the following instructions on to kafka : 
1. "debit 100 from account A"
2. "send email to user A that his account is debited by 100"
and there is a consumer that does the following :
1. does the actual work of 'debit 100'
2. does the actual work of 'sending mail'

说，消费者实例崩溃了，我启动了另一个实例。 现在，消费者告诉kafka“重播”（以具体化其数据视图） 就现实世界而言，消费者不应该按照这些指令采取行动（这将导致不需要的借记和电子邮件），而只是阅读数据并做任何需要实现其观点的事情。

问题是，消费者如何知道它之前已经对一条消息“采取了行动”，因此，不应该重新采取行动。它只需要在内部捕获消息状态信息吗？

Answer 1

您可以做的一件事是让您的消费者手动提交偏移量。为此，您需要将默认使用者配置 enable.auto.commit 从 true 更改为 false。然后，在您的消费者应用程序中，在您成功处理消息后，您提交偏移量。