3.5.1 消费者提交分区偏移量
3.5 消费者提交分区偏移量消费者提交偏移量是为了保存分区的消费进度。因为Kafka保证同一个分区只会分配给消费组中的唯一消费者，所以即使发生再平衡后，分区和消费者的所有权关系发生变化，新消费者也可以接着上一个消费者记录的偏移盘位置继续消费消息。但是消费者即使记录了分区的偏移量，仍然无法解决消息被重复消费的问题。例如，消费者l每隔10秒提交一次偏移量，在10秒时提交的偏移量是100，下一次提交的日们可点是20秒。在20秒之前，消费者l又消费了30条消息，然后消费者l突然挂掉了。由于偏移量现在仍然
