RocketMQ消费模式有几种?

RocketMQ主要有两种消费模式:CLUSTERING集群消费(默认)和BROADCASTING广播消费。

在CLUSTERING模式下,一个ConsumerGroup中的Consumer实例根据队列分配策略算法为Consumer分配队列,平均分摊(默认)消费消息。例如,如果Topic是Test的消息发送到该主题的不同队列中,发送了有100条消息,其中一个ConsumerGroup有3个Consumer实例,那么根据队列分配算法,每个队列都会有消费者,每个消费者实例只消费自己队列上的数据,消费完的消息不能被其他消费实例消费。

在BROADCASTING模式下,消息会被所有在该Topic的ConsumerGroup中的Consumer实例共同消费。

请注意,消费模式在创建Consumer时指定,不同的消费模式其内部机制也不同,消息的消费方式、记录消费进度、消息的消费状态等也都各不相同。

发表评论

后才能评论