kafka教程-Offset偏移量(位移)和手动提交 作者:马育民 • 2021-12-04 19:37 • 阅读:10171 说明正常情况下 报错、崩溃情况下 手动提交-同步提交提交请求后,broker响应之前应用程序会 一直阻塞 用 commitSync() 提交由 poll() 方法返回的最新偏移量,如果提交成功马上返回,提交失败则抛出异常。 缺点由于 阻塞 ,会限制应用程序的吞吐量。虽然可以通过降低提交频率来提升吞吐量,但一旦发生再均衡,会增加重复消息的数量。 手动提交-异步提交提交请求后,broker响应之前应用程序 不会阻塞 缺点如果服务器返回 提交失败,异步提交 不会重试 原文出处:/show_1IX2LYaqPzQi.html