在实践 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 的标准来定制化消费。