在手动提交期间，如果特定偏移量失败，但序列中的下一个偏移量提交成功，会发生什么？

Question

我正在写一个使用投票机制的kafka消费者，在这个机制中，我每次投票都会收到100条消息。在消费消息之后，我一个接一个地手动提交偏移量。在提交偏移量时，有时我会收到100条消息中的一条消息的错误。Rest偏移量提交成功。

Offsets
1,2,3,4,5,6,7,....100

假设偏移量5提交失败，但不包括偏移量5，所有偏移量都成功提交。

那么，在这种情况下，提交失败的偏移量会发生什么？由于偏移量是按顺序移动的，我是否会在下一次轮询中获得提交失败的偏移量？

我的初步调查显示，它在下一次轮询中读取失败的偏移量。需要在这方面的专业意见。

Answer 1

不需要单独提交每个偏移量。如果你提交偏移量X，这意味着所有较小的偏移量也会被提交。