Spout已经开启ack 和 fail 机制,后面处理逻辑中出现了异常,但是没有重发出现异常的数据.按我自己的理解,出现异常应该调用 fail 方法,但是实际上调用了 ack 方法,不知道哪个地方有问题。
https://www.oschina.net/question/257063_126896