在消费消息时面临问题。我有5个代理和5个分区,其中有4个副本。我已经创建了3个消费者,并试图通过连接到Zookeeper来消费消息。但我得到了关于单个消费者的所有消息,而不是将消息发送到消费者的其余部分。请给我一些建议。
发布于 2014-05-07 22:43:43
..。通过在主题中拥有并行性的概念-分区-,Kafka能够在消费者进程池中提供排序保证和负载平衡。这是通过将主题中的分区分配给使用者组中的使用者来实现的,以便每个分区仅由组中的一个使用者使用。 ...
cf:https://kafka.apache.org/documentation.html#intro_consumers
https://stackoverflow.com/questions/23368653
复制相似问题