我有一个主题a和10个不同的消费群体（比如a1、a2、a3……a10）。每个消费群体的消费率是不同的（假设10 msg/s、30 msg/s、50 msg/s…….15 msg/s）。每一条消息都会为每个组广播。我的a1最慢，a3最快。每个消费群体会得到所有的消息还是会有消息下降，因为不同的消费率。
sxissh061#
消费群体是相互独立的。每个消费群体都将收到来自主题的所有消息；他们不会丢弃消息。请记住您的主题的保留配置—如果某个使用者组远远落后于主题，以致于该主题的数据已过期，则它将无法再读取这些消息。参考文件：http://kafka.apache.org/documentation.html#intro_consumershttp://kafka.apache.org/documentation.html#kafka_mqhttp://kafka.apache.org/documentation.html#basic_ops_consumer_lag
1条答案
按热度按时间sxissh061#
消费群体是相互独立的。每个消费群体都将收到来自主题的所有消息；他们不会丢弃消息。
请记住您的主题的保留配置—如果某个使用者组远远落后于主题，以致于该主题的数据已过期，则它将无法再读取这些消息。
参考文件：
http://kafka.apache.org/documentation.html#intro_consumers
http://kafka.apache.org/documentation.html#kafka_mq
http://kafka.apache.org/documentation.html#basic_ops_consumer_lag