在我的设置中，我有一个消费者组，它有三个进程（一个服务的3个示例），可以从kafka消费。我发现第一个节点正在接收所有的流量。如果一个节点被手动终止，则下一个节点将拾取所有kafka通信量，但最后一个剩余节点处于空闲状态。
期望的行为是所有消息均匀地分布在消费者组中的所有示例上，这就是我认为应该发生的事情。据我所知，Kafka的工作方式是，它应该在一个消费群体的所有成员之间平均分配信息。我的理解正确吗？我一直在试图弄清楚，为什么只有一个消费群体的成员获得了所有的流量却没有运气。有什么想法/建议吗？
1条答案
按热度按时间w46czmvw1#
您需要确保主题有多个分区才能并行使用它。使用者组中的使用者从代理获取一个或多个已分配的分区，但除非使用者脱机，否则同一组中的多个使用者永远不会共享单个分区。一个主题拥有的分区数等于一个使用者组中可以从一个主题馈送的最大使用者数。