关于Kafka中max.poll.records与多分区行为的技术问询

问题1：理想情况下，每个分区是否会写入250条消息？ #

是的。round-robin分区器会以严格轮询的方式将消息依次分发到各个分区，2000条消息平均分配给8个分区，每个分区刚好能得到250条。这里的理想状态指生产者无重试、分区器逻辑正常运行、Topic分区数量全程稳定。

问题2：若消费者端max.poll.records为默认值500，每个消费者实例能否一次拉取完对应分区的250条记录？ #

可以。max.poll.records的作用是限制单次poll()调用返回的总记录数上限，而非针对单个分区做限制。由于每个消费者实例仅负责1个分区，该分区仅存250条记录，远低于500的阈值，再加上消息尺寸极小，fetch.max.bytes的限制可忽略，因此一次poll()就能拉取完对应分区的全部消息。

问题3：消费者实例1是否会获取到消息1、9、17、25等序列的消息？ #

是的。round-robin分区器会把第1条消息分配到分区0，第2条到分区1……第8条到分区7，第9条又回到分区0，以此循环。消费组内8个消费者实例与8个分区一一对应（默认Range分配策略下，分区数与消费者数相等时，每个消费者会分到一个独立分区），如果消费者实例1被分配到分区0，那么它将获取所有发往该分区的消息，也就是序列为1、9、17、25……间隔为8的消息。

内容的提问来源于stack exchange，提问作者Viking22