kafka教程-Offset偏移量(位移)和手动提交

说明

正常情况下

报错、崩溃情况下

手动提交-同步提交

提交请求后,broker响应之前应用程序会 一直阻塞

用 commitSync() 提交由 poll() 方法返回的最新偏移量,如果提交成功马上返回,提交失败则抛出异常。

缺点

由于 阻塞 ,会限制应用程序的吞吐量。虽然可以通过降低提交频率来提升吞吐量,但一旦发生再均衡,会增加重复消息的数量。

手动提交-异步提交

提交请求后,broker响应之前应用程序 不会阻塞

缺点

如果服务器返回 提交失败,异步提交 不会重试


原文出处:/show_1IX2LYaqPzQi.html