apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.26k stars 11.7k forks source link

[Bug] DefaultLitePullConsumer PullThreadNums Parameter not effective. #8695

Closed luozongle01 closed 2 months ago

luozongle01 commented 2 months ago

Before Creating the Bug Report

Runtime platform environment

MacOS 11.7.10

RocketMQ version

develop

JDK Version

Oracle JDK 8

Describe the Bug

I found that the setPullThreadNums parameter does not work when using the DefaultLitePullConsumer. No matter how many are set, there will always be 20 threads.

Steps to Reproduce

-

What Did You Expect to See?

setPullThreadNums Should take effect.

What Did You See Instead?

There are 20 threads working.

image image

Additional Context

No response