java - 是否可以使用 Kafka 将多个任务组合成一个数据条目？

Question

想象一下，系统得到了一个 JSON 输入的订单。该订单需要处理多个任务——其中一些需要本地数据处理，一些——需要来自外部 API 的响应等，因此每种类型的任务都有不同的时间估计。每个任务输出都提供 JSON 输出，包括订单 ID。

因此，我将所有这些任务添加到 Kafka，并且它们正在得到处理。问题是 - 当最后一个订单的任务被处理时，如何根据订单 ID 组合所有这些？

如果我遗漏了一些逻辑或选择了错误的工具（工具 X 更适合） - 请告诉我。任何基于主题/流的建议都可以。

标签： javaapache-kafkamessage-queue

Answer 1

卡夫卡不是你想要的正确工具。虽然可以使用它和数据库来构建您的应用程序，但它需要大量自定义代码。

考虑使用像temporal.io这样开箱即用的编排器来解决您的需求。