关于storm里面的对象生存周期问题
来源：12-9 -Storm整合Kafka功能开发
慕函数7570418
2020-04-07
老师你好，我想问一下storm里面的各个组件中，在哪个地方创建的对象是会重复创建调用直到storm被kill，哪些地方的对象是初始化之后一直活到storm被kill。比如，我在某一个bolt的开头定义一个集合，往里面放值，那这里面的值是会一直保存到storm被kill还是每次到这个组件所有对象全部重新创建，这个集合重新初始化为空
写回答
1回答
-
Michael_PK
2020-04-07
以storm对接kafka为例来说这事情：只要你的storm读取到了指定的kafka的topic的数据，那么当数据被storm接收到进行处理之后，offset也提交了，那么这条数据的生命周期也就到了。如果你后续出现了问题，你需要从指定的topic的offset去重新消费的话，那么你只要传入这个offset，这些数据又会被重新到storm来处理
062020-04-07
相似问题