RocketMQ——Consumer消费模式

RocketMQ的Consumer有两种消费模式,通过 consumer.setMessageModel(MessageModel.BROADCASTING) 和consumer.setMessageModel(MessageModel.CLUSTERING)设置 广播模式 当使用广播消费模式时,MQ 会将每条消息推送给集群内所有订阅该topic和tag的客户端,保证消息至少被每台机器消费一次。
相关文章
相关标签/搜索