Rocket消费者代码中使用了SQL92标准
consumer.subscribe("TopicTest", MessageSelector.bySql("a between 0 and 3"));
出现日常MQClientExcept异常 The broker does not support consumer to filter message by SQL92
此时在服务器rocketMq的broker配置文件broker.conf
中添加下面这句:
# 让‘过滤消息’时支持SQL92标准
enablePropertyFilter=true
重启namesrv与broker服务就解决问题了,在控制台也能看到(没添加之前是false):