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相关推荐

RocketMQ特性、专业术语（Producer,Producer Group,Consumer Group,Topic,Message,Tag,Broker,Name Server）等
RocketMQ 是什么 Github 上关于 RocketMQ 的介绍:RcoketMQ 是一款低延迟.高可靠.可伸缩.易于使用的消息中间件.具有以下特性: 支持发布/订阅(Pub/Sub)和点对点 ...
启动：错误信息FDT and ATAGS support not compiled in – hanging分析解决
启动:错误信息FDT and ATAGS support not compiled in – hanging => tftp 0xa0000000 Image;tftp 0xa2000000 f ...
RocketMQ错误消息重试策略之Consumer的重试机制（Exception情况）
consumer端重试消费者端的失败,分为2种情况,一个是exception,一个是timeout. exception 消息正常的到了消费者,结果消费者发生异常,处理失败了.例如反序列化失败,消息 ...
RocketMQ错误消息重试策略之Consumer的重试机制（timeout情况）
timeout 比如由于网络原因导致消息压根就没有从MQ到消费者上,那么在RocketMQ内部会不断的尝试发送这条消息,直至发送成功为止! 也就是说,服务端没有接收到消息的反馈,既不是成功也不是失败, ...
rocketmq中的broker设计与实现
1.broker启动启动逻辑在BrokerStartup和BrokerController中. 监听端口是1091. 默认存储目录是System.getProperty("user.hom ...
RocketMQ - nameSrv和Broker
RocketMQ RocketMQ是一个统一的消息传递引擎,轻量级的数据处理平台. Name Server Name Server充当路由消息的提供者,生产者(Producer)或消费者(Custom ...
错误: 找不到android.support.v7.app.AppCompatActivity的类文件
今天拉取了最新的代码,突然Android Studio 编译报错错误:无法访问AppCompatActivity找不到android.support.v7.app.AppCompatActivity ...
iOS12-Swift5-Xcode10 Buildtime错误：/xx/Pods/Target Support Files/Pods-xx/Pods-xx.d
Xcode-Buildtime错误: /Users/项目路径/Pods/Target Support Files/Pods-当前target名/Pods-当前target名.debug.xcconfi ...
阿里二面：RocketMQ 集群 Broker 挂了，会造成什么影响？
大家好,我是君哥.今天分享 RocketMQ 的 Broker 挂了,会带来什么影响. 面试官:你好,如果 RocketMQ 集群中的一个 Broker 挂了,会造成什么影响呢? 我:Broker 挂 ...

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

1.出现问题

2.修改broker配置文件

3.重启RocketMQ

4.查看是否启用

RocketMQ 错误：The broker does not support consumer to filter message by SQL92相关推荐

最新文章

热门文章