**结束。**此问题需要详细的调试信息。它目前不接受答案。**想改进这个问题吗?**更新问题,使其成为堆栈溢出的主题。
6年前关门了。改进这个问题在使用消息时遇到问题。我有5个代理和5个分区和4个副本。我已经创建了3个消费者,并试图通过连接到zookeeper消费的消息。但是我在单个消费者上获取所有消息,而不是将消息传递给其他消费者。请给我一些建议。
alen0pnh1#
[…]通过对主题中的分区具有并行性的概念,kafka能够在消费进程池上提供排序保证和负载平衡。这是通过将主题中的分区分配给使用者组中的使用者来实现的,这样每个分区就只被组中的一个使用者使用。[…]囊性纤维变性:https://kafka.apache.org/documentation.html#intro_consumers
1条答案
按热度按时间alen0pnh1#
[…]通过对主题中的分区具有并行性的概念,kafka能够在消费进程池上提供排序保证和负载平衡。这是通过将主题中的分区分配给使用者组中的使用者来实现的,这样每个分区就只被组中的一个使用者使用。[…]
囊性纤维变性:https://kafka.apache.org/documentation.html#intro_consumers