Kafka手动提交偏移量的作用到底是什么???
Kafka手动提交1.一条一条处理并提交偏移量,某一条偏移量不提交,后面的偏移量提交后会覆盖掉前面的偏移量2.批量处理数据,不提交,会整体的偏移量都不提交。但是当新的数据进入kafka后,消费者也能接收新消息。但是偏移量没有提交到服务端,当发生分区再均衡时,其他消费者分到了这个分区,就会重复消费。没有发生分区再均衡的情况下,消费者本地存着一个分区的偏移量,所以在拉取的时候,会根据本地的偏移量去往后拉取数据,并一直更新本地的偏移量。但是发生分区再均衡的时候,新的消费者去获取分区偏移量时,就是老的偏