在使用RocketMQ使用SQL过滤消息的时候,出现下面错误
原因是我们的配置文件没有开启SQL过滤功能,我们需要在每个配置文件中添加下面命令
java">#开启过滤消息时支持SQL92标准
enablePropertyFilter=true
接着我们重启namesrv与broker服务就解决问题
java"># 1.进入bin目录
cd /root/mq/rocketmq/bin
# 2.关闭NameServer
sh mqshutdown namesrv
# 3.关闭Broker
sh mqshutdown broker
# 4.通过jps查看进程是否已关闭
jps
# 5. 重启
然后通过rocketmq-console来查看,集群中的这个属性是否为true,为true就可以了