项目中使用了RocketMQ，没有显式的创建和Topic和MessageQueue，在消息发送时，就创建了Topic和 个MessageQueue 此时想要修改MessageQueue的数量方式如下： 通过producer.createTopic方法创建 通过控制台方式创建 修改metaq源码重新编译borker，使用broker的配置信息覆盖defaultTopic的配置信息。 参考：http ...
2021-07-06 01:02 0 960 推荐指数：
rocketMq和kafka的性能对比和原理，Kafka vs RocketMQ Topic数量对单机性能的影响 阿里巴巴中间件团队对rocketMq，kafka和rabbitMq的发送消息性能的测试，在单机同步发送的场景下，Kafka>RocketMQ>RabbitMQ。如下图 ...
转载 https://blog.csdn.net/a417930422/article/details/50663639 1 同一个订阅组内不同Consumer实例订阅不同topic消费混乱问题调查 图1： 背景说明 ...
待续 ...
新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized ...
引言 上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能，受到了程序猿们的广泛关注，其中大家对这种单纯的发送场景感到并不过瘾，因为没有任何一个网站的业务只有发送消息。本期，我们就来模拟一个真实的场景： 消息的发送和订阅一定是共存 ...
最近在使用rocketmq 发送消息，出现了No route info of this topic 异常，但奇怪的是我的其它的服务都可以成功发送，唯有crs服务不能成功发送，在网上搜索的解决方式基本上都是： ocketmq运行时提示 No route info of this topic 异常 ...
