项目中使用了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删除。