每个 Topic 都有分区

  • 生产者可以指定分区,也可以自动分区
    • 可以指定消息存放的分区
    • 可以根据 mq 自动选择存放分区
  • 数据以分区为单位进行并发和持久化
  • 同一个分区保证消费顺序
  • 同一个消费者只投递一次()
    • Topic 中的消息被平均分配到同组的消费者
    • 每个消费组都会得到 Topic 中的所有消息