【已解决】在使用RocketMQ消费消息的时候，提示不支持SQL92的错误：CODE: 1 DESC: The broker does not support consumer to filter message by SQL92
- RocketMQ
- 时间：2022-10-19 14:29
- 4795人已阅读
简介
【已解决】在使用RocketMQ消费消息的时候，提示不支持SQL92的错误
CODE: 1 DESC: The broker does not support consumer to filter message by SQL92
🔔🔔好消息!好消息!🔔🔔
如果您需要注册ChatGPT，想要升级ChatGPT4。凯哥可以代注册ChatGPT账号，代升级ChatGPT4
有需要的朋友👉:微信号
在使用RocketMQ的时候，我们知道消费者，可以根据不同条件进行过滤消息来消费的。比如说通过tag进行过滤。tag是一种最简单但是也最使用的一种过滤方式。但是，有些情况下，我们需要复杂的过滤。这个时候，可能tag过滤就不一定能满足了，其实RocketMQ也支持SQL语法的过滤。
在使用sql语法过滤步骤：
在生产者发送消息的时候，在消息体中put我们自定义的属性。如下：
注意：再不同版本的rocketMQ下，可能有setUserProperty.而不是putUserProperty方法
在消息的消费者订阅消息的时候，可以bysql进行过滤。
启动消费者的时候，发现如下错误：
从错误信息中，我们可以看到，是当前的broker不支持SQL92语法过滤。
那么怎么修改呢？
分情况：分单机环境和集群环境
单机情况下，直接在borker.conf中添加
#支持sql92 enablePropertyFilter=true
在集群情况下，修改broker-m.conf和broker-s.conf.然后重启broker即可。
重启完rocketMQ后，重启消费者服务。我们就可以看到，消费者值消费了i>4的消息了。如下图：
