我在 RabbitMQ 的 Quorum Queues 上做 POC,特别关注故障转移机制。在我的例子中,我有两个节点(例如 NodeA 和 NodeB)和一个位于 NodeA 上的 Quorum 队列。现在,每当我向 NodeA 的 Quorum 队列发布测试消息时,我都可以在 NodeB 上看到相同的消息。
现在在测试故障转移机制并停止NodeA时,我无法发布任何消息,也看不到quorum queue中的任何消息,我认为NodeB没有被提升为新的领导者。我假设领导者会被自动提升,我需要做任何事情来让另一个节点领导者吗?
亲切的问候