rocketmq的两种消费模式

消费端默认走集群模式,   同时多个消费组消费某个topic消息会 竞争消费,ack确认由broker完成   若是改为广播消费,消费信息的Offset由各个消费者本身控制,数据库 若是某个涉及到mq的应用 宕机(上面有消费者),重启应用会重复消费以前的消息,能够定时的提交消费的位置到数据库或者缓存,避免这个问题.      感受广播模式没有什么使用场景:即便广播消费,某个应用至少部署两个节点吧,
相关文章
相关标签/搜索