yangou commented on issue #10524: URL: https://github.com/apache/pulsar/issues/10524#issuecomment-840077113
Have you tune the receiver queue size. When consumer polls the messages from pulsar, if the requested messages is greater than total number of messages, pulsar won't be able to evenly distribute the messages. Pulsar uses poll model, not push model. If you want consumers to be evenly distributed, try setting the receiver queue size to 1. https://pulsar.apache.org/docs/en/cookbooks-message-queue/#client-configuration-changes -- 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: us...@infra.apache.org