kafka同步异步消费和消息的偏移量（四）

1. 消费者位置(consumer position) 由于kafka服务端不保存消息的状态，因此消费端须要本身去作不少事情。咱们每次调用poll()方法他老是返回已经保存在生产者队列中还未被消费者消费的消息。消息在每个分区中都是顺序的，那么必然能够经过一个偏移量去肯定每一条消息的位置。web 偏移量在消费消息的过程当中处于重要的做用。若是是自动提交消息，那么poll()方法会去在每次获取消息的时

>>阅读原文<<