Describe the bug
The throughput of the consumer side is only about 10M. Whether it is to modify the queuesize of the consumer side or to add more consumer nodes, it is of no use.
To Reproduce
Install pulsar to k8s cluster through helm and test normal production and consumption functions
Modify some configuration parameters in helm chart and some initialization scripts, such as the authorization information of pulsar manager user
It looks better after deployment. The pulsar manager background interface can be opened. Except for a few functions with problems, everything looks good
Start developing consumer server code and prepare for testing
The local environment runs in standalone mode, which is very fast. Each batch of 2,000 messages can be obtained, and the next batch can be obtained immediately
But it doesn't work when deployed online. The production end can write more than 100MB, but the consumer end is only about 10M
Expected behavior
The consumer end is expanded from 10 to more than 100, and the consumption throughput has not changed. Modify the consumer end code such as receiverQueueSize and maxNumMessages, and just print the number of messages obtained on the consumer end. Without any business logic, the throughput still cannot be increased
Screenshots
Desktop (please complete the following information):
broker: 8c16g 100g ssd
proxy: 8c16g 100g ssd
bookie: 8c32g 1.5T essd * 3
Describe the bug The throughput of the consumer side is only about 10M. Whether it is to modify the queuesize of the consumer side or to add more consumer nodes, it is of no use.
To Reproduce
Expected behavior The consumer end is expanded from 10 to more than 100, and the consumption throughput has not changed. Modify the consumer end code such as receiverQueueSize and maxNumMessages, and just print the number of messages obtained on the consumer end. Without any business logic, the throughput still cannot be increased
Screenshots
Desktop (please complete the following information): broker: 8c16g 100g ssd proxy: 8c16g 100g ssd bookie: 8c32g 1.5T essd * 3
Additional context