原文：rocketmq如何新增topic
新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized RemotingCommand updateAndCreateTopic ChannelHandlerContext ctx, RemotingC ...
2019-12-08 20:21 0 1461 推荐指数：
相关推荐
待续 ...
项目中使用了RocketMQ，没有显式的创建和Topic和MessageQueue，在消息发送时，就创建了Topic和 4个 MessageQueue 此时想要修改MessageQueue的数量方式如下： 通过producer.createTopic方法创建； 通过控制台方式 ...
最近在使用rocketmq 发送消息，出现了No route info of this topic 异常，但奇怪的是我的其它的服务都可以成功发送，唯有crs服务不能成功发送，在网上搜索的解决方式基本上都是： ocketmq运行时提示 No route info of this topic 异常 ...
原文地址：https://blog.csdn.net/chenaima1314/article/details/79403113 rocketmq运行时提示 No route info of this topic 异常产生的原因可能是 ①Broker禁止自动创建Topic，且用户没有通过手 ...
本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。 一.Topic 首先看看官方的定义： Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。 具体来说，一个Topic ...
多个服务器的情况下： 相同 topic 、consumerGroup tag 默认 均衡消费消息 相同 topic 、consumerGroup 当存在不同Tag的时候，会导致消费混乱，比如TagA的消息被TagB的消费者消费了。 相同topic 不同consumerGroup 默认 ...