RocketMQ我这边是3个RocketMQ的集群，主从，感觉是无法切换到其他消费者上消费？-[阿里云_云淘科技]

RocketMQ我这边是3个RocketMQ的集群，主从，用了controller和proxy。生产者、消费者客户端也有3个。这样是能正常生产消费的。
问题是：现在是消息一直在其中一台消费者上消费的，我把那一台消费者关闭了，后续生产了消息就无法消费消息了。感觉是无法切换到其他消费者上消费？

以下为热心网友提供的参考意见

根据你的描述，RocketMQ集群中的一台消费者关闭后，新的消息无法被消费。这可能是因为消费者的消费进度没有及时提交，导致消息一直停留在队列中等待消费。在RocketMQ中，消费者的消费进度默认是每隔30秒提交一次，如果在这30秒内消费者没有正常处理完消息，那么这些消息将会被重新放回队列中等待下一次消费。

你可以尝试以下几种解决方案：

检查消费者是否正常运行，如果有异常，需要尽快修复。
检查消费者组的配置是否正确，确保所有的消费者都在同一个消费者组中。
检查消费者的订阅关系是否正确，确保每个消费者都订阅了所有需要消费的主题。
如果以上都没有问题，你可以尝试手动提交消费者的消费进度，让消息尽快被消费。

以下为热心网友提供的参考意见

如果您的RocketMQ集群配置了主从部署，使用了Controller和Proxy，并且拥有3个生产者和消费者客户端，理论上应该能够正常进行消息的生产和消费。

当您关闭其中一台消费者时，由于RocketMQ采用推模式（Push Model）来将消息主动推送给消费者，消息会自动分配给可用的消费者。如果您关闭了其中一台消费者，RocketMQ会尝试将消息重新分配给其他可用的消费者去消费。

但是，有几个可能导致消息无法在其他消费者上消费的情况：

消费者组名称和订阅关系：请确保所有消费者客户端都属于同一个消费者组，并且订阅了相同的Topic和Tag。否则，消息无法在不同消费者间共享和切换。
配置正确的Namesrv地址：通过在消费者客户端中指定正确的NameServer地址，确保消费者可以正确连接到RocketMQ集群，并获得最新的Topic和订阅关系信息。
消费模式配置：在创建消费者时，要确认消费模式是否设置为集群模式（默认）。如果使用广播模式，消息将被所有消费者消费，而不仅限于一个消费者。
消息过滤规则：检查消息过滤规则是否与消费者的订阅关系匹配。如果消息无法满足消费者的过滤规则，那么消息将不会推送给该消费者。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/11981.html