Kafka如何帮助实现队列和发布订阅的抽象？

Question

Kafka 文档指出：

消费者使用消费者组名称标记自己，发布到主题的每条消息都会传递到每个订阅消费者组中的一个消费者实例。消费者实例可以位于不同的进程或不同的机器上。

如果所有消费者实例都有相同的消费者组，那么这就像传统的队列平衡消费者负载一样。

如果所有消费者实例都有不同的消费者组，那么这就像发布-订阅一样，所有消息都广播给所有消费者。

我对此有几个疑问：
1) 为什么发布的消息会转到到消费者组的单个消费者实例？从分区读取数据不是消费者的责任吗？ go 在这里是什么意思？
2）对特定主题感兴趣的消费者应该从他们感兴趣的分区中读取。消费者群体的相关性是什么？
3）这对实现队列和发布者-订阅者的抽象有何帮助？

Answer 1

在 Kafka 中，一个主题可以有多个分区，如果一个消费者组有 X 个消费者，则该主题的分区将在消费者之间拆分。 （即：如果您有 1 个带有 2 个分区的主题，并且您有一个带有 2 个消费者的消费者组，则每个消费者将从 1 个分区消费，在相同的情况下，如果消费者组只有 1 个消费者，则该消费者将从 2 个分区读取) 消费者组基本上协调（是协调者）具有主题和分区的不同消费者。如果您在同一个 CG 中有 4 个消费者和 1 个崩溃，则消费者组会将崩溃消费者的分区提供给同一 CG 中可用的其他消费者，以便处理这些分区中的信息（如果 CG 没有重新分配不同的如果消费者崩溃，某些分区将永远不会被读取）。

如果消费者在同一个 CG 中，那么发送到主题的信息将在他们之间分发。如果每个消费者都有不同的CG，那么他们都会得到所有的消息。

希望现在更清楚，Kafka 文档需要改进。