在Kafka中,如何等待所有子消息完成后再发送父消息?

pgky5nke  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(268)

我有一个主题1和一个消息父,在这个父里面它包含多个子消息,比如child1…5。这些是我的主题,对于每个主题,我都有一堆工人在处理关于这个主题的信息。
主题1:主题中的父项\u消息\u主题2中的子项\u消息\u主题3:子项\u消息\u输出主题4:父项\u消息\u输出
我想要的是:等待所有5个子消息在child\u msg\u out主题上完成,然后在parent\u msg\u out主题上报告相应的父消息完成。
做这件事的好方法是什么?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题