发送消息的生产者
生产者nacos配置:
消费者配置:
发送消息日志:
但是三组消费者组都进行了消费,下面是截取的日志内容:
各位大佬我想一个应用模块只提供一个topic,根据不同的tag来进行消费,现在所有消费者组都消费了.有什么解决办法吗
2022-09-24追加:
按理说应该是3个消费者组都接收到了消息,因为三个不同组名的消费者组订阅了同一个topic的不同tag,
但是其中两个消费者组应该根据tag进行过滤.现在公司大佬说可能是mq底层没有过滤,目前还不知道具体原因
生产者nacos配置:
发送消息日志:
但是三组消费者组都进行了消费,下面是截取的日志内容:
各位大佬我想一个应用模块只提供一个topic,根据不同的tag来进行消费,现在所有消费者组都消费了.有什么解决办法吗
2022-09-24追加:
按理说应该是3个消费者组都接收到了消息,因为三个不同组名的消费者组订阅了同一个topic的不同tag,
但是其中两个消费者组应该根据tag进行过滤.现在公司大佬说可能是mq底层没有过滤,目前还不知道具体原因
同一个topic不同的group当然会消费多次啊，想要3个消费者只有其中 一个消费的话，他们的group设置成一样才行
我希望的是一个服务模块只有一个topic,该模块底下所有的消费者都订阅此topic,根据tag的不同来进行消费
经过大佬提示,这个2.2.1版本的stream mq的tag过滤是无效的,想使用要不改源码要不使用mq tag过滤有效的版本.而且大佬并不推荐我三个消费者组订阅同一个topic不同tag.还是一个组一个topic,这样出了问题更容易解决.
1 个赞