[Bug] RMQ 5.3.3版本消费端consumer接收不到消息
Before Creating the Bug Report
-
[x] I found a bug, not just asking a question, which should be created in GitHub Discussions.
-
[x] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
-
[x] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment
CenterOS7
RocketMQ version
RocketMQ 版本经测试 5.3.3 版本以及 5.3.2 版本发现此问题,5.2.0 版本无此问题!
JDK Version
1.8
Describe the Bug
Consumer 所在的服务器有 2 个ip,一个是10.10.20.151,一个是192.168.20.151。SpringBoot 服务配置的 server.address 是10.10.20.151。生产服务生产消息后,消费端接收不到数据。通过 RMQ 的控制台 的 Consumer 页面,找到对应的 topic ,点击右侧的 consume detail,发现consumerClient的ip为192.168.20.151。生产者、RMQ 服务的 ip 都使用的 10 网段 ip。未升级 RMQ 前的版本是 5.2.0,升级到5.3.3版本后发现前面提到的问题,经测试 5.3.2 版本也有该问题。目前项目已经退回 5.2.0 版本。同时发现 5.3.3 版本在使用 dashboard 查看消息时,message 页面的详情中的 Consumer 会出现两个,其中一个不知道是哪来的,项目中从未定义过。比如项目中定义的 Topic 为 test-app-consumer-MQ_TEST_INFO,结果消息详情的 consumerGroup中出现了test-MQ_TEST_INFO的消费组,而在 dashboard 的 consumer 页面找不到此消费组,通过rocketmqadmin通过命令也查不到。
Steps to Reproduce
见上面的描述
What Did You Expect to See?
消费端能够正常消费到消息
What Did You See Instead?
消费端未能收到消息
Additional Context
No response
我用的5.3.3,用的simple 走的 proxy 8081。 比如我有topic叫 topicTest,必须手动创一个%RETRY%topicTest ,不然就报错说%RETRY%topicTest不存在。 然后消费者组consumerGroup必须设置和主题一个名字topicTest,不然就报%RETRY%topicTest_topicTest不存在。
总结就是:非常离谱
我用的5.3.3,用的simple 走的 proxy 8081。 比如我有topic叫 topicTest,必须手动创一个%RETRY%topicTest ,不然就报错说%RETRY%topicTest不存在。 然后消费者组consumerGroup必须设置和主题一个名字topicTest,不然就报%RETRY%topicTest_topicTest不存在。
总结就是:非常离谱
之前的版本遇到过这个问题吗?
我用的5.3.3,用的simple 走的 proxy 8081。 比如我有topic叫 topicTest,必须手动创一个%RETRY%topicTest ,不然就报错说%RETRY%topicTest不存在。 然后消费者组consumerGroup必须设置和主题一个名字topicTest,不然就报%RETRY%topicTest_topicTest不存在。 总结就是:非常离谱
之前的版本遇到过这个问题吗?
第一次用。nodejs的client也是有毒,我还自己修了一下。准备弃了。
Any detail information for “can not consume messages correctly”?
Any error in client logs?
我用的5.3.3,用的simple 走的 proxy 8081。 比如我有topic叫 topicTest,必须手动创一个%RETRY%topicTest ,不然就报错说%RETRY%topicTest不存在。 然后消费者组consumerGroup必须设置和主题一个名字topicTest,不然就报%RETRY%topicTest_topicTest不存在。
总结就是:非常离谱
By design,RocketMQ Broker will auto create %RETRY%{GID} as pull reytry topic, and create %RETRY%{GID}_{TOPIC} as pop retry topic.
我的版本是 5.3.1 ,也是消费不到,报这个错误:MQClientException: CODE: 17 DESC: No topic route info in name
我5.3.2 也是报这个错,还要自己创建重试队列,不都是自动创建的吗?以前 4.x版本都没有这样,而且还发现消息集群,消息会发送到 从节点,主节点没数据。就很离谱。brokerId 都是标记好的,主是0,从是1,消息跑去从节点,非常离谱