生产者-消费者的卡夫卡传播模型

Question

我有一个主题A和10个不同的消费者群体(比如A1，A2，A3 ....A10)。每个消费者组的消费速率是不同的(假设10 msg/s、30 msg/s、50 msg/s .......15 msg/s)。

为每个组广播每个消息。我的A1最慢，A3最快。每个消费群体会得到所有的消息，还是会有消息丢弃，因为不同的消费率。

Answer 1

消费者群体是相互独立的。每个消费者组将接收来自该主题的所有消息；它们不会丢弃消息。

记住你的主题的保留配置-如果一个消费者组落后太多以至于该主题的数据已经过期，那么它将不再能够读取这些消息。

参考文献：

• 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