消费者_offset手动提交

虽然自动提交offset十分简单便利，但由于其是基于时间提交的，开发人员难以把握offset提交的时机。因此Kafka还提供了手动提交offset的API。

手动提交offset的方法有两种方式：

1. commitSync同步提交:必须等待offset提交完毕，再去消费下一批数据。
2. commitAsync异步提交:发送完提交offset请求后，就开始消费下一批数据了。

两者的区别：

• 相同点是，都会将本次消费的一批数据的最高的偏移量提交；
• 不同点是，同步提交阻塞当前线程，一直到提交成功，并且会自动失败重试（由不可控因素导致，也会出现提交失败）；而异步提交则没有失败重试机制，故有可能提交失败。

实时效果反馈

1. 关于Kafka消费者offset手动的描述，错误的是：

A commitSync同步提交：必须等待offset提交完毕，再去消费下一批数据。

B commitAsync异步提交 ：发送完提交offset请求后，就开始消费下一批数据了。

C 同步和异步提交相同点是，都会将本次提交的一批数据最高的偏移量提交。

D 同步和异步提交都是一直到提交成功，并且都会自动失败重试。

答案：

1=>D 异步提交则没有失败重试机制。