kafka将主题分区的信息存储在名为 __consumer_offsets .
读取偏移量的请求仅由分区的前导提供，提交的偏移量存储在前导上。
同步复制副本还必须与前导分区同步，因此它们会发出获取请求，例如从哪个偏移量读取分区前导的数据。
读取前导分区后，它们还更新其 _consumer_offsets 分区。
当系统启动时，sysc中的任何一个复制副本都将被选为引导，并且它们具有最新提交的偏移量。
因此，分配给该分区的使用者将从最新的前导获取最后一次消耗的偏移量，并开始从该偏移量读取。
希望它能回答你的问题。