Kafka消费者手动提交消息偏移

生产者每次调用poll()方法时，它老是返回由生产者写入Kafka但尚未消费的消息，若是消费者一致处于运行状态，那么分区消息偏移量就没什么用处，可是若是消费者发生崩溃或者有新的消费者加入群组，就会触发再均衡，完成再均衡以后，每一个消费可能分配到新的分区，而不是以前处理的那个，为了可以继续以前的工做，消费者须要读取每一个分区最后一次提交的偏移量，而后从偏移量制定的地方开始工做。消费者会往一个__co

>>阅读原文<<