[GitHub] [rocketmq] crzbird opened a new issue, #6456: Bug in ConsumeMessageService#updateCorePoolSize: Can not increase consumeExecutor coreSize.

[via GitHub]

crzbird opened a new issue, #6456:
URL: https://github.com/apache/rocketmq/issues/6456

   **BUG REPORT**
   
   1. Please describe the issue you observed:
   ConsumeMessageService#updateCorePoolSize cannot increase consumeExecutor 
coreSize.because "corePoolSize" input must < 
"this.defaultMQPushConsumer.getConsumeThreadMax()",but consumeExecutor coreSize 
and maxSize has same value after init,which means there is no way to  increase 
coreSize.
   - What did you do (The steps to reproduce)?
   call method 
"org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService#updateCorePoolSize"
   - What is expected to see?
   increase consumeExecutor coreSize
   - What did you see instead?
   nothing,just return;
   2. Please tell us about your environment:
   JDK8 AND rocketmq-client:5.1.0
   3. Other information (e.g. detailed explanation, logs, related issues, 
suggestions on how to fix, etc):
   <img width="880" alt="image" 
src="https://user-images.githubusercontent.com/40804675/227158705-ddf943a0-bb04-4fda-b467-89a0a3dc5a65.png";>
   <img width="1181" alt="image" 
src="https://user-images.githubusercontent.com/40804675/227160209-a1b7c592-c154-4ce9-affd-e3f72bd08abf.png";>
   
   <img width="846" alt="image" 
src="https://user-images.githubusercontent.com/40804675/227159628-3844e05b-083d-44bc-9368-241d2120d040.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.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org