pl6306 opened a new issue #6162: Can't control the queue size in shared subscription with multiple topics URL: https://github.com/apache/pulsar/issues/6162 **Describe the bug** In the use case where I have multiple consumers of the type pulsar.ConsumerType.Shared, the receiver_queue_size=1 parameter is ignored? It works fine when it is a single topic. It also doesn't work in a partitioned topic **To Reproduce** Steps to reproduce the behavior: pts = ['topic-1','topic-2','topic-3'] consumer = client.subscribe(topic=pts, subscription_name=subscription, receiver_queue_size=1, max_total_receiver_queue_size_across_partitions=1, consumer_type=pulsar.ConsumerType.Shared, initial_position=pulsar.InitialPosition.Earliest) **Expected behavior** I expect that each consumer to get a receiver_queue_size of 1. But it doesn't **Additional context** Using version 2.4.2
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
