風暴BaseBasicBolt在哪裏處理ack（）函數？

Question

正如我們所知，當使用BaseBasicBolt時，我們不需要調用ack()函數。

但我通過BaeBasicBolt，IBasicCode的代碼，找不到任何實現代碼。

所以我不知道如何在BasicBolt調用ack()方法？

Answer 1

我發現它。

當TopologyBuilder.setBolt（）時，有一個BasicBoltExecutor處理ack和失敗邏輯。