在风暴文档中提到,风暴重放了处理超时的元组.我的问题是风暴是否自动执行此操作(不调用原始spout上的fail())或者是原始spout的重要责任是重放元组(调用fail()并且重放应该在内部实现,甚至在外部实现)?
java apache-storm
apache-storm ×1
java ×1