rocketmq3.26研究之五DefaultMQPushConsumer

DefaultMQPushConsumerweb rocketmq客户端消费者实现,从名字上已经能够看出其消息获取方式为broker往消费端推送数据,其内部实现了流控,消费位置上报等等。express 重要字段 1 String consumerGroup 消费者组名,必须设置 须要注意的是,多个消费者若是具备一样的组名,那么这些消费者必须只消费同一个topic,具体缘由参见rocketmq问题汇
相关文章
相关标签/搜索