架构问题：我们有一个基于apachekafka的事件处理系统和多个生成/发送事件的系统。每个事件都有一些数据，包括一个id，我需要实现一个“id is complete”事件。例子： Event_A(id) Event_B(id) Event_C(id) 异步接收，并且只有在接收到所有3个事件后，才需要发送 Event_Complete(id) . 问题是我们有多个消费者集群，而且我们的数据库最终是一致的。
一种简单的方法是使用最终一致的db来存储每个id的事件，并添加一个“cron”作业来最终捕获竞争条件。
这感觉像是一个可能已经解决的问题。因此，我的问题是，有没有更好的方法（不向图片引入一致的数据存储）？
非常感谢！