Kafka如何向众多消费群体广播

Question

我是Kafka的新手，我将非常感谢关于下一个案件的澄清。

Kafka文档在“消费者立场”一段中说：

问题是，如果只有一个消费者能够拉出特定的信息，那么如何向多个消费者群体广播呢？

Answer 1

如果一个主题有10个分区和3个使用者实例(C1、C2、C3)都属于同一个使用者组，我们可以有不同的使用者模型，允许读取并行，如下所示

每个使用者使用单个流。在这个模型中，当C1启动时，主题的所有10个分区都映射到同一个流，并且C1开始从该流消费。当C2启动时，Kafka重新平衡两个流之间的分区。因此，每个流将被分配给5个分区（取决于重新平衡html" target="_blank">算法，也可能是4对6)，每个使用者从其流中消费。类似地，当C3启动时，分区再次在3个流之间重新平衡。注意，在此模型中，当从分配给多个分区的流中消费时，消息的顺序将在分区之间混杂。

每个消费者使用多个流（例如C1使用3，C2使用3，C3使用4）。在这个模型中，当C1启动时，所有的10个分区都被分配给3个流，并且C1可以使用多个线程同时使用3个流。当C2开始时，分区在6个流之间重新平衡，类似地，当C3开始时，分区在10个流之间重新平衡。每个使用者可以同时从多个流中使用。注意，这里的流数和分区数是相等的。如果流的数量超过了分区，一些流将不会获得任何消息，因为它们不会被分配任何分区。

如果存在另一个消费者组，则对该消费者组内的消费者应用相同的处理