假设系统得到一个命令作为json输入。顺序需要处理多个任务—其中一些需要本地数据处理，一些需要外部api的响应，等等，因此每种类型的任务都有不同的时间估计。每个任务输出都提供json输出，包括order id。
所以，我把所有这些任务都添加到Kafka中，它们正在被处理。问题是-在处理最后一个订单的任务时，如何基于订单id将所有这些任务组合起来？
如果我错过了一些逻辑或选择了错误的工具（工具x将更适合）-让我知道。任何基于主题/流的建议都可以。