Rocketmq: What circumstances will messages not be consumed or delay consumed?

Created on 10 Apr 2021  ·  2Comments  ·  Source: apache/rocketmq

I have more than five hundred topic in one cluster with six nodes, I create the topic like this :

./mqadmin updateTopic -c MyCluster -n 192.168.1.100:9876 -r 16 -w 16 -t topic1;
./mqadmin updateTopic -c MyCluster -n 192.168.1.100:9876 -r 16 -w 16 -t topic2;
...
./mqadmin updateTopic -c MyCluster -n 192.168.1.100:9876 -r 16 -w 16 -t topic500;
I can send the message without delay ,but I find sometime that the client can not consume the message because the broker do not have consume client.How to fix this bug?
image

question

Most helpful comment

Hi @VAEAZE , refer to this issue https://github.com/apache/rocketmq-spring/issues/339
set different instance name can fix it.

All 2 comments

Hi @VAEAZE , refer to this issue https://github.com/apache/rocketmq-spring/issues/339
set different instance name can fix it.

@maixiaohai ,at first ,I start two instance,when I find that may be the reason,I have stop all of them.Ant then start one of the instance,but when the topic is create more and more,the problem still happen,

Was this page helpful?
0 / 5 - 0 ratings