怎么使用IBasic Bolt实现自动确认

2023-04-07 02:44:00 确认 IBasic Bolt

如果你想要使用IBasicBolt来实现自动确认,你需要做的第一件事是实现一个类来实现这个接口。第二步是在你的bolt类中添加一个execute方法,并且在这个方法中添加一个collector参数。第三步是使用这个collector来发送你的tuple。最后,你需要在你的类中实现ack方法。

相关文章