前言

rocketMQ消费者是按照消费组来的，每个消费组里面的topic对应的tag都是唯一的。如果多个相同的消费组含有不同的tag，那么只会记录最后一次的消费组tag。如此有些消息就丢失了，应该tag不符合，被过滤了。
这里考虑，最后的tag更新在哪里？
消息被过滤丢失了，是broker端做的，如何处理的？

参考