[Bug] consumerManagerThreadPoolQueueCapacity has settings but is not used

[frinda]

Before Creating the Bug Report

• [X] I found a bug, not just asking a question, which should be created in GitHub Discussions.

• [X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

• [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

SUSE Linux Enterprise Server 12 SP5

RocketMQ version

4.9.x

JDK Version

JDK 8

Describe the Bug

consumerManagerThreadPoolQueueCapacity has settings but is not used https://github.com/apache/rocketmq/blob/4.9.x/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java

Steps to Reproduce

NA

What Did You Expect to See?

consumerManagerThreadPoolQueueCapacity has settings and be used

What Did You See Instead?

consumerManagerThreadPoolQueueCapacity has settings but is not used

Additional Context

No response

[humkum]

The consumerManageExecutor is initialized as a newFixedThreadPool, which's queue size is Integer.MAX_VALUE. What's the value do you want to set? And did you meet some problems caused by this parameter?

[frinda]

I haven't had a problem because of this. but this may cause OOM

[github-actions[bot]]

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

[github-actions[bot]]

This issue was closed because it has been inactive for 3 days since being marked as stale.