关于kafka中消费者的分区分配策略

在说分区分配之前我们先要强调一下consumer采用pull（拉）模式从broker中读取数据 。因为push（推）模式很难适应消费速率不同的消费者，因为消息发送速率是由broker决定的。它的目标是尽可能以最快速度传递消息，但是这样很容易造成consumer来不及处理消息，典型的表现就是拒绝服务以及网络拥塞。 下面我们来看一下如下所示的分区和消费者组的图 你可能会想这个图中的消费者会消费到主题中

>>阅读原文<<