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的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。