
消费者组kafak若干的消费者是需要放在一个分组当中的而进行消费的时候也是以组为单位的。Offset维护有一个主题有三个分区消息在进入不同的分区进行存储的时候每个分区都有自己offset记录来表示这条消息在分区当中的位置。这里面记录的就是每一个消费者组中的每一个消费者消费的位置。包括每个主题某一个分区消费到什么位置现在是记录在了主题当中。消费者在消费了数据之后是要去更新消费的位置。如果还是使用的是push方式那么很难保证每个消费者消费的速率是一样的这样很难适应不同速率的消费者。push模式是尽可能以最快的速度传递消息但是这样很容易造成consumer来不及处理消息。push对于消费者来说是不适合的。而pull模式对于消费者来说是比较适合的根据consumer能力适当的去消费消息。生产者生产出来的数据会及时的推送到topic中存储producer会像broker中发送数据采用的是push模式。而consumer根据自己的消化能力处理能力去向broker中去主动的拉取数据。