EZLippi opened a new issue #2777:
URL: https://github.com/apache/rocketmq/issues/2777


   
   **BUG REPORT**
   
   1. Please describe the issue you observed:
   consumer is subscribing a topic, when modify topic permission to not 
readable or just delete this topic, we hope to see the consumer will not 
dispatch pull request to broker , but actually pull request will always ongoing 
with a exception except restart the consumer.
   the exception stack trace is like this:
   `2021-04-02 15:24:54.018 WARN 
[NettyClientPublicExecutor_2:RocketmqClient:130] execute the pull request 
exception
   org.apache.rocketmq.client.exception.MQBrokerException: CODE: 17  DESC: 
topic[topic-flash2] not exist, apply first please! 
   See http://rocketmq.apache.org/docs/faq/ for further details. BROKER: 
192.168.60.39:10911
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.processPullResponse(MQClientAPIImpl.java:794)
 ~[rocketmq-client-4.8.0.jar:4.8.0]
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.access$200(MQClientAPIImpl.java:167)
 ~[rocketmq-client-4.8.0.jar:4.8.0]
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl$2.operationComplete(MQClientAPIImpl.java:745)
 [rocketmq-client-4.8.0.jar:4.8.0]
        at 
org.apache.rocketmq.remoting.netty.ResponseFuture.executeInvokeCallback(ResponseFuture.java:54)
 [rocketmq-remoting-4.8.0.jar:4.8.0]
        at 
org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$2.run(NettyRemotingAbstract.java:319)
 [rocketmq-remoting-4.8.0.jar:4.8.0]
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
[?:1.8.0_211]
        at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) 
[?:1.8.0_211]
        at java.util.concurrent.FutureTask.run(FutureTask.java) [?:1.8.0_211]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_211]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_211]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_211]`
   
   as the code show below, when there is no queue left for a topic , a 
exception will throw from AllocateStrategy, 
   then processQueueTable will not be updated
   
   
![image](https://user-images.githubusercontent.com/5326814/113392601-f6017e00-93c7-11eb-9178-30c75935062e.png)
   
   
   2. Please tell us about your environment:
   rocketmq 4.8.0


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to