工作小总结&小工具类 Redis AI相关 MQTT Maven mybatis ChatGPT uniapp zookeeper Thymeleaf语法 POI-TL sa-token PowerDesigner16.5 taos数据库 frp echarts Actor模型及Akka thingsboard 大疆无人机对接 CI/CD 教师资格证小任务面试其他职场淘宝客支付宝支付 HBuilder X Flink Java集合类多线程 ES Ribbon eureka Docker java游戏网络通信 Nacos 芋道管理系统 Solr 分布式相关 Dubbo 数据结构 EasyPOI Drools RocketMQ JS 七天深入MySQL实战营书籍 kafka spring Java基础 java web 若依(ruoyi) 分布式事务面试宝典 mysql java8新特性 spring cloud ElasticSearch学习系列 HM_leadnews 即时通讯并发思维&学习 VUE 宝塔面板算法刷题设计模式 RabbitMQ学习系列教程 P3C规范 JVM学习系列反射自定义注解网络美文 PHP源码经验分享资源 git项目 websocket 网赚数据库读写分离测试相关其他随笔 shiro学习系列 fremarker学习系列学习笔录-spring boot 网络文章工作小总结

简介【已解决】在使用RocketMQ消费消息的时候，提示不支持SQL92的错误 CODE: 1 DESC: The broker does not support consumer to filter message by SQL92

🔔🔔🔔好消息!好消息!🔔🔔🔔

有需要的朋友👉:联系凯哥微信号 kaigejava2022

在使用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的消息了。如下图：