我应该使用什么模式来聚合 Apache Kafka 中的不同类型的事件？

Question

0

我正在尝试使用 Kafka 进行事件处理，但我有点难以理解我应该使用什么模式。

我的用例是这样的：

• 一个消费者等待一种类型的事件。
• 处理该事件时，同一消费者需要使用传入事件属性的子集为不同的主题生成几种不同类型的事件。
• 然后，一旦所有这些事件都被它们各自的消费者消费（顺序无关紧要），我需要知道它并发回聚合响应。 我研究过构建 Saga 状态机、事件聚合器、扇入/扇出和分散/聚集作为可能的解决方案，但我不确定什么是最好的方法。卡夫卡流？

任何建议将不胜感激。