我有要求在 KafkaStream 中收到一条记录，我根据逻辑将这条记录分成 n 条记录。这 n 条记录被推送到另一个流。这 n 条记录是并行处理的。但是我需要知道 n 个作业的完成情况，这样我才能发回响应。你能告诉我如何实现这一目标吗？
请您参考如下方法:
我认为最简单的方法是设置一个消费者来订阅该流并对其进行处理。
Q : 823053937
我有要求在 KafkaStream 中收到一条记录，我根据逻辑将这条记录分成 n 条记录。这 n 条记录被推送到另一个流。这 n 条记录是并行处理的。但是我需要知道 n 个作业的完成情况，这样我才能发回响应。你能告诉我如何实现这一目标吗？
请您参考如下方法:
我认为最简单的方法是设置一个消费者来订阅该流并对其进行处理。
程序员必备工具大全
