如何处理RocketMQ订阅关系一致性检查

订阅关系不一致

基本概念

消费者实例

Consumer consumer = ONSFactory.createConsumer(consumerProperties);即创建一个实例

GID

Group ID,一个消费者组使用同一个ID,处理相同的业务

TOPIC

主题,可以被多个GID订阅

TAG

消息标签,用来区分同一个topic下不同消息

出现情况

  • 同一个消费者组实例订阅的topic不一致
  • 同一个消费者组实例订阅了相同的topic,但tag数量不一致
  • 同一个消费者组是咧订阅了相同的topic,tag数量一致,但输入的tag顺序不同