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


   
   
   1. Please describe the issue you observed:
   my broker file is as follow:
   brokerClusterName = RaftCluster
   brokerName=RaftNode00
   enableDLegerCommitLog=true
   dLegerGroup=RaftNode00
   dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
   ## must be unique
   dLegerSelfId=n0
   brokerRole=ASYNC_MASTER
   flushDiskType=ASYNC_FLUSH
   transientStorePoolEnable=true
   transientStorePoolSize=3
   
   in dledger cluster , role is changed dynamic, we use async_flush, and set 
transientStorePoolEnable=true, if set role to ASYNC_MASTER, when broker start 
up , transientStorePool will not enabled because of brokerRole is not master, 
   
![image](https://user-images.githubusercontent.com/5326814/100339588-0322f080-3015-11eb-81d4-f603224d8afe.png)
    if this broker node elected as leader,  client send message to this broker 
will failed, errors is like this:
   `[pool-1-thread-1]17:33:07 566  WARN (RocketmqClient:130) - sendKernelImpl 
exception, resend at once, InvokeID: 1799213012626878715, RT: 0ms, Broker: 
MessageQueue [topic=topic_mainstay-flash-test, brokerName=RaftNode00, queueId=2]
   org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2  DESC: 
[REJECTREQUEST]system busy, start flow control for a while
   For more information, please visit the url, 
http://rocketmq.apache.org/docs/faq/
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:665)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:505)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:487)
        at 
org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:431)`
   
   SendMessageProcessor will check whether to reject request, 
   
![image](https://user-images.githubusercontent.com/5326814/100340487-3dd95880-3016-11eb-8683-0aea94fd74f1.png)
   
![image](https://user-images.githubusercontent.com/5326814/100340567-5ea1ae00-3016-11eb-888a-b502d2f773a0.png)
   rejectRequest will return true because we enableTransientPool but 
transientPool fail to init because of role setting,
   
![image](https://user-images.githubusercontent.com/5326814/100340726-94469700-3016-11eb-8d12-f9afc267d417.png)
   
   
   
   


----------------------------------------------------------------
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