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