用MessageSelector.bySql来使用sql筛选消息时报错：Exception in thread “main” org.apache.rocketmq.client.exception.MQClientException: CODE: 1 DESC: The broker does not support consumer to filter message by SQL92

一、单机情况下在broker.conf中添加:

支持sql92
enablePropertyFilter=true

集群情况下修改:broker-m.conf和broker-s.conf。然后重启broker即可。

可在集群—配置里面查看enablePropertyFilter是否为true