在消费者重启后调用getOffsetsBefore kafka simple consumer api(0.8.2)时,返回已经提交的偏移量 .

根据kafka代码https://apache.googlesource.com/kafka/+/c27c768463a5dc6be113f2e5b3e00bf8d9d9d602/core/src/main/scala/kafka/server/KafkaApis.scala

我们获得的偏移量将是在请求中提供给定时间戳之前的一组(一个或多个)日志段上的消息 .

  • 在kafka简单消费者api重启的情况下,有没有办法(kafka机制......不包括存储偏移到持久存储)以获得最后一次提交的偏移后的下一个偏移?

  • commitOffsets api的目的是什么,我们无法在上次提交的偏移量后得到下一个偏移量?