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的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。