rocketmq3.26研究之五DefaultMQPushConsumer

DefaultMQPushConsumerweb rocketmq客戶端消費者實現,從名字上已經能夠看出其消息獲取方式爲broker往消費端推送數據,其內部實現了流控,消費位置上報等等。express 重要字段 1 String consumerGroup 消費者組名,必須設置 須要注意的是,多個消費者若是具備一樣的組名,那麼這些消費者必須只消費同一個topic,具體緣由參見rocketmq問題匯
相關文章
相關標籤/搜索