0

我在一个有六个节点的集群中有超过五百个主题,我创建这样的主题:

./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 topic500;

我可以毫不拖延地发送消息,但有时我发现客户端无法消费消息,因为代理没有消费客户端。如何修复这个错误? 在此处输入图像描述

4

1 回答 1

0

做以下检查

  • 超过 1 个消费者实例在一台机器上启动。如果是这样,使每个消费者实例的客户端ID或客户端名称不同
  • 此消费者组中的消费者实例c_fy_core子不同的主题和标签。如果是这样,请确保一个消费者组中的所有消费者实例子相同的主题和标签
于 2021-04-21T06:39:19.487 回答