订阅关系不一致怎么办？

问题描述

在不同的 JVM 中启动了多个 Consumer，并且给相同的 Consumer ID 配置了不同的 Topic，或者是相同的 Topic 但 Tag 不同，最终导致订阅关系不一致，消息不符合预期。

错误代码示例

错误示例一：同一个订阅组（CID-MQ-FAQ）订阅的 Topic 不同（分别是 MQ-FAQ-TOPIC-1、MQ-FAQ-TOPIC-2）。

JVM-1上的代码:

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();
JVM-2上的代码

     Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-2", "NM-MQ-FAQ", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();
错误示例二：同一订阅组（CID-MQ-FAQ）订阅的 Topic 相同，但 Tag 不同（分别NM-MQ-FAQ-1、NM-MQ-FAQ-2）。

JVM-1上的代码:

    Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ-1", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();
JVM-2上的代码:

     Properties properties = new Properties();
    properties.put(PropertyKeyConst.ConsumerId, "CID-MQ-FAQ");
    Consumer consumer = ONSFactory.createConsumer(properties);
    consumer.subscribe("MQ-FAQ-TOPIC-1", "NM-MQ-FAQ-2", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });
    consumer.start();
建议解决方案

请确保在不同 JVM 中使用相同的 Consumer ID 启动多个 Consumer 时，配置的 Topic 和 Tag 是一致的。