我有一个关于Apache风暴的问题。我当前的应用程序有多个项目，它们不断运行以更新来自其他服务的最新数据。当一个项目完成后，它将在一个可修改的时间间隔后重新开始更新数据。
我们要搬到Apache风暴和Kafka的新版本。我们的设计是将项目元数据放入Kafka，然后storm将读取Kafka并启动项目。但是由于我们有很多螺栓来处理数据，所以我们还没有找到任何解决方案来指示项目何时完成更新数据以更新其状态，以便调度器可以知道这个项目已经完成了一段时间，然后在特定的时间间隔后将其再次放到kafka。
所以我的问题是对于这样的设计，是否有任何方法来处理项目状态，知道项目何时在风暴中完成？先谢谢你