DLQ的默认读权限是不开的，所以在console上打开DLQ的读权限就可以了
在 2018年6月5日 上午9:10，李承霖 <lichenglin0...@126.com> 写道： > > > Hi, > > 我在代码中声明了一个DefaultMQPushConsumer尝试监听死信队列里的消息，却在代码中获得如下异常 > > > 08:33:30.588 [RebalanceService] ERROR RocketmqClient - > AllocateMessageQueueStrategy.allocate Exception. > allocateMessageQueueStrategyName=AVG > java.lang.IllegalArgumentException: mqAll is null or mqAll empty > at > org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely.allocate(AllocateMessageQueueAveragely.java:39) > at > org.apache.rocketmq.client.impl.consumer.RebalanceImpl.rebalanceByTopic(RebalanceImpl.java:283) > at > org.apache.rocketmq.client.impl.consumer.RebalanceImpl.doRebalance(RebalanceImpl.java:224) > at > org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.doRebalance(DefaultMQPushConsumerImpl.java:946) > at > org.apache.rocketmq.client.impl.factory.MQClientInstance.doRebalance(MQClientInstance.java:952) > at > org.apache.rocketmq.client.impl.consumer.RebalanceService.run(RebalanceService.java:44) > at java.lang.Thread.run(Thread.java:748) > > > 原因可能是客户端无法找到相应的queue，但我确信死信队列是存在的 且拥有一个QUEUE。 > > > 除了死信队列外，其他可以正常消费。 > > Rocket是对死信队列有特殊处理吗？那么我该如何消费死信队列里的消息？？？ > > > 谢谢 > >
