我是 Kafka 的新手，非常感谢您对下一个案例的澄清。
Kafka 文档在“消费者位置”段落中说：
"我们的主题被划分为一组完全有序的分区，每个分区 其中一个消费者在任何给定时间消费。”
根据上面的说法，如果少数消费者组订阅了一个主题，而生产者将向该主题内的特定分区发布消息，那么只有一个消费者可以拉取消息。
问题是，如果只有一个 Consumer 可以提取特定消息，如何向多个 Consumer Group 广播？
【问题讨论】：
标签： apache-kafka
一般有两种消息模式：
Kafka通过消费者组的概念同时支持两者。 同一组中的消费者遵循共享队列模式。群组中只有一个消费者可以收到消息。
不同的消费者群体遵循发布-订阅模式。对于每条消息，订阅该主题的所有消费者组都将获得该消息的副本。
一个有用的参考： https://dzone.com/articles/dont-use-apache-kafka-consumer-groups-the-wrong-wa
【讨论】：
如果一个主题有 10 个分区和 3 个消费者实例（C1、C2、C3 按此顺序启动）都属于同一个消费者组，我们可以有不同的消费模型，允许读取并行，如下所示
每个消费者使用一个流。 在这个模型中，当 C1 启动时，主题的所有 10 个分区都映射到同一个流，并且 C1 开始从该流中消费。当 C2 启动时，Kafka 重新平衡两个流之间的分区。因此，每个流将被分配到 5 个分区（取决于重新平衡算法，它也可能是 4 对 6）并且每个消费者从其流中消费。同样，当 C3 启动时，分区在 3 个流之间再次重新平衡。请注意，在此模型中，当从分配给多个分区的流中消费时，消息的顺序将在分区之间混乱。
每个消费者使用多个流（例如 C1 使用 3，C2 使用 3，C3 使用 4）。 在这个模型中，当 C1 启动时，所有 10 个分区都分配给 3 个流，C1 可以使用多个线程同时从 3 个流中消费。当 C2 启动时，分区在 6 个流之间重新平衡，类似地，当 C3 启动时，分区在 10 个流之间重新平衡。每个消费者可以同时从多个流中消费。请注意，这里的流和分区的数量是相等的。如果流的数量超过分区，则某些流将不会收到任何消息，因为它们不会被分配任何分区。
如果有另一个消费者组，相同的过程将应用于该消费者组内的消费者
【讨论】：
consumer group 中只有一个消费者可以拉取消息。但是所有 consumer groups 收到消息。
因此，如果您希望所有消费者都收到消息，请为它们分配不同的consumer groups。每条消息都会发送到每个消费者组，但在一个组内，它只发送给一个消费者。
阅读Consumer 部分here。
【讨论】：