RocketMQ（07）——消费者通过用户属性进行过滤

Posted 2022-12-08 elim168

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了RocketMQ（07）——消费者通过用户属性进行过滤相关的知识，希望对你有一定的参考价值。

消费者通过用户属性进行过滤

生产者在发送消息的时候可以通过Message的putUserProperty()放Message中放一些用户自定义属性，比如下面这样。

@Test
public void testFilterSend() throws Exception 
   
  DefaultMQProducer producer = new DefaultMQProducer("group1");
  producer.setNamesrvAddr

以上是关于RocketMQ（07）——消费者通过用户属性进行过滤的主要内容，如果未能解决你的问题，请参考以下文章