确定Apache Storm中子流处理的结束

问题描述

我有一个基于Apache Storm的项目，该项目从Kafka主题中给出其元组。在每条Kafka消息中，我都有一个从外部系统生成的ID。也许我在卡夫卡有多封邮件，它们具有相同的ID。具有类似ID的邮件将顺序插入到Kafka中，没有任何间隙。我想检测所有具有相同ID的消息已由风暴拓扑处理。如何检测到所有具有相同ID的邮件均已被Storm处理？还应该注意，在某些情况下，我在Kafka中有100K条具有相同ID的消息，也许我的风暴拓扑可能在处理这些消息时由于某种原因而崩溃了。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）