RocketMQ使用filter失败,报The broker does not support consumer to filter message by SQL92

tech2023-07-12  101

在实践 RocketMQ 的基于 UserProperty 来对消息进行过滤消费时,启动 consumer 时出现了如下的报错信息: 导致无法正常启动 consumer,通过查看 RocketMQ 中的BrokerConfig 类,发现了问题的原因如下: 在 MQ 的默认配置里,关闭了对 property filter 的支持。 来到 RocketMQ 安装目录的 conf 目录下 修改 broker 的属性文件broker.conf,添加下面的属性配置即可正常启动。

# 开启对 propertyfilter的支持 enablePropertyFilter = true filterSupportRetry = true

接下来,重启namesrv与broker服务,再次启动consumer,就一切顺利了! 注意: 如果你是使用 terminal 打开的 namesrv 和 broker,那么你需要关闭当前的 terminal,开启新的 terminal 开启服务(我就遇见了不关闭重启失败的情况) 之所以,出现不关闭 terminal 重启失败的问题,是因为在 RocketMQ 的底层使用的时 Netty 做的通信,一个终端对应的本地服务端口是不会变化的,也就是没办法更新配置信息,可能携带有缓存的问题。


补充说明:使用RocketMQ-4.7.1的版本时,可能出现修改broker.conf配置,按照上述方法重启无效的问题。这是可以采用mqadmin命令来手动更新设置,命令如下:

mqadmin.cmd updateBrokerConfig -blocalhost:10911 -kenablePropertyFilter -vtrue mqadmin.cmd updateBrokerConfig -blocalhost:10911 -kfilterSupportRetry -vtrue

接下来,就可以使用 userProperty 结合 SQL92 的标准来定制化消费。

最新回复(0)