I briefly tested how these two spouts handle failure in processing tuples. I randomly generated error in updateState method, and batch seems to be replayed. In transactional spout, seems like exactly same batch is replayed but in opaque spout, batch itself is increasing in it's size although it seems to contain all the items in previous batch. Am I getting right?
- difference between opaque and transactional kafka spout 이승진
