如果一个主题有10个分区，3个使用者示例（c1、c2、c3按该顺序开始）都属于同一使用者组，那么我们可以有不同的使用者模型，允许如下所示的读取并行性
每个消费者使用一个流。在这个模型中，当c1启动时，主题的所有10个分区都Map到同一个流，并且c1从该流开始消费。当c2开始时，Kafka重新平衡两个流之间的分区。因此，每个流将被分配到5个分区（取决于重新平衡算法，它也可能是4对6），每个消费者从其流中消费。类似地，当c3启动时，分区在3个流之间再次重新平衡。注意，在这个模型中，当从分配给多个分区的流中消费消息时，消息的顺序将在分区之间混淆。
每个使用者使用多个流（假设c1使用3，c2使用3，c3使用4）。在这个模型中，当c1启动时，所有的10个分区都被分配给3个流，并且c1可以使用多个线程同时使用3个流中的数据。当c2启动时，分区在6个流之间重新平衡，类似地，当c3启动时，分区在10个流之间重新平衡。每个消费者可以同时消费多个流。注意，这里的流和分区的数量是相等的。如果流的数量超过了分区，一些流将不会得到任何消息，因为它们不会被分配任何分区。
如果存在另一个消费者组，则对该消费者组中的消费者应用相同的过程

问得好。

举个例子，我有一个主题，叫做complaint，有两个分区p1，p2
现在我有两个消费群，叫做group1，有两个消费群c1和c2，group2，有两个消费群c3
在这里，我将消息从p1路由到c1，p2路由到c2，我订阅了另一个名为c3的消费者，但它在不同的组中，所以在这里，整个消息的副本也被发送到该消费者

一次中只有一个消费者 consumer group 我可以拉信息。但所有 consumer groups 获取消息。
因此，如果您希望所有消费者都能获得这些消息，请为它们分配不同的值 consumer groups . 每条消息都发送给每个消费者组，但在一个组中，它只发送给一个消费者。
阅读 Consumer 在这里。

通常有两种消息传递模式：
共享队列：所有使用者都订阅一个消息队列。每个消费者相互竞争，对于每条消息，只有一个消费者会得到它。
发布-订阅：每条消息都会广播给订阅的所有消费者。所以所有的消费者都会得到相同的信息。
Kafka通过消费群体的概念同时支持了两者。同一组中的消费者遵循共享队列模式。一个组中只有一个消费者可以获得消息。
不同的消费者群体遵循发布-订阅模式。对于每条消息，订阅该主题的所有消费者组都将获得消息的副本。
有用的参考：https://dzone.com/articles/dont-use-apache-kafka-consumer-groups-the-wrong-wa