为什么rocketMQ默认情况下没有将一个JVM内的所有的生产者和消费者都放置在同一个MQClientInstance下?
问题描述:版本是4.3. 代码就是 创建一个Consumer一个Producer,两者都是使用了默认的属性,仅指定topic,group nameServer必要属性。 这个时候发现 c…
RocketMQ生产者发送消息失败是如何规避重试时发送给同一个broker?
在没有开启Broker故障延迟机制的的情况下, Producer发送消息的时候有失败重试机制。第一次发送消息的时候 会随机选择一个MessageQueue,MessageQueue…
rocketMQ 4.5.1 No route info of this topic
rocketMQ 版本4.5.1集群配置2m-2s出现问题客户端偶而出现:No route info of this topic其他信息topic 是有创建的,客户端出现这种情况是偶发在 rocke…
阿里的RocketMQ丢数据
阿里的RocketMQ(http)问题:先生产A tag 100条数据,起一个消费者用个新的分组ID去消费A tag的数据,必定只能消费32条。咨询阿里技术说这是正常现象…
springboot整合rocketmq问题
选用的依赖包:<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> …
docker rocketmq-console connect to <外网:10911> failed
docker run -d -p 9876:9876 --name rmqserver foxiswho/rocketmq:server-4.5.1docker run -d -p 10911:10911 -p 10909:10909\ --name rmqbroker --li…
关于SpringBoot使用Roocketmq报错No route info of this topic
第一次使用Roocketmq,我的程序放在本机上,Roocketmq放在阿里云的一台服务器上,我在主配置文件中配置了服务器公网ip和Roocketmq的topic,名为stock…
rocketmq 广播模式消费,消费者消费消息后,rocketmq-console依旧显示消息堆积
我的rocketmq配置是双主双从,异步模式的。我发现一个问题,就是我使用广播模式消费消息,消息有被消费者消费,但是rocketmq-console控制台依旧显示消…
rocketmq connect to <47.95.201.47:10911> failed
在使用rocketmq-console连接rocketmq时遇到了下面的错误: Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect …