項目中使用了RocketMQ,沒有顯式的創建和Topic和MessageQueue,在消息發送時,就創建了Topic和 4個 MessageQueue
此時想要修改MessageQueue的數量方式如下:
- 通過producer.createTopic方法創建;
- 通過控制台方式創建;
- 修改metaq源碼重新編譯borker,使用broker的配置信息覆蓋defaultTopic的配置信息。
參考:https://www.cnblogs.com/dyfh/p/4113677.html
項目中使用了RocketMQ,沒有顯式的創建和Topic和MessageQueue,在消息發送時,就創建了Topic和 4個 MessageQueue
此時想要修改MessageQueue的數量方式如下:
參考:https://www.cnblogs.com/dyfh/p/4113677.html
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。