出现这种错误百度了下，然后自己试了下，因为自己搭的是主从的集群，所以有点问题。
首先你如果报了这个错
The broker does not support consumer to filter message by SQL92
然后你就要去改配置文件
如果是集群像我这种就要改两个配置文件，broker-a.properties,broker-a-s.properties
加上一行
enablePropertyFilter = true
就可以了。
然后通过rocketmq-console来查看，集群中的这个属性是否为true，为true就成功了