正解, 赞👍
> 在 2018年6月5日,下午12:29,卢松 <[email protected]> 写道:
>
> DLQ的默认读权限是不开的,所以在console上打开DLQ的读权限就可以了
>
> 在 2018年6月5日 上午9:10,李承霖 <[email protected]> 写道:
>>
>>
>> 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是对死信队列有特殊处理吗?那么我该如何消费死信队列里的消息???
>>
>>
>> 谢谢
>>
>>