RocketMQ 错误：The broker does not support consumer to filter message by SQL92

本文主要是介绍RocketMQ 错误：The broker does not support consumer to filter message by SQL92，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.出现问题

Connected to the target VM, address: '127.0.0.1:56480', transport: 'socket'
Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: CODE: 1  DESC: The broker does not support consumer to filter message by SQL92
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/at org.apache.rocketmq.client.impl.MQClientAPIImpl.checkClientInBroker(MQClientAPIImpl.java:2102)at org.apache.rocketmq.client.impl.factory.MQClientInstance.checkClientInBroker(MQClientInstance.java:455)at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.start(DefaultMQPushConsumerImpl.java:648)at org.apache.rocketmq.client.consumer.DefaultMQPushConsumer.start(DefaultMQPushConsumer.java:693)at com.abc.consumer.FilterConsumer.main(FilterConsumer.java:32)

2.修改broker配置文件

###1.编辑broker.conf文件
vim broker
####2.添加属性
enablePropertyFilter=true

3.重启RocketMQ

### 查看当前运行容器
docker ps
### 重启RocketMQ brocker
docker restart rmqbroker

4.查看是否启用

这篇关于RocketMQ 错误：The broker does not support consumer to filter message by SQL92的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---