一个broker放了2个分区,每个分区分别有10消息。首先,消费组只有一个消费者A,拉取消息,在处理到第二条消息时,消费者B加入,此时,触发分区均衡,分区均衡会一直等待消费者A提交offset才会完成吗?这里提交都是手动同步提交offset的方式。自己做了一下实验,好像是等待消费A处理完所有消息提交offset,才会完成分区均衡。!
kafka消费者拉取的消息是按批次的,一个批次大概有2000条,当有新的消费者加入时,是要等待这个批次完成,之后不会再发新的消息批次给它。
你的答案