KafkaConsumer position（）vs committed（）？

Question

committed：获取给定分区的上次提交偏移量（无论提交是由这个进程还是另一个进程进行的）。此偏移量将在发生故障时用作消费者的位置。此调用将阻止执行远程调用，以从服务器获取最新提交的偏移量。

这是否意味着如果consumer.poll（）获取了50条从偏移量101到150的消息，并且consumer有手动偏移量提交。并且使用者仍在处理这50条消息,所以最后提交的偏移量是100。现在committed（）将返回100，但position将返回151（因为已经获取了消息101到150）？

Answer 1

是的。没错。

当您poll()或seek()并对应于使用者收到的最新消息偏移量时，位置将自动更新。

提交位置是指客户端在提交调用（手动或自动）中使用的最新偏移量。