@RunLLM what is

max_total_receiver_queue_size_across_partitions

?

max_total_receiver_queue_size_across_partitions

sets an upper limit on the total number of messages that can be queued across all partitions for a consumer. If the sum of receiver queues for all partitions exceeds this value, the queue size for each partition is reduced accordingly. The default is 50,000 messages. This helps control memory usage when consuming from partitioned topics or multiple topics at once, and is supported in Java, Python, C++, and other Pulsar clients. For partitioned topics, the effective per-partition queue size is the minimum of

receiver_queue_size

and

max_total_receiver_queue_size_across_partitions / NumPartitions

(Pulsar docs, Java config). Would you like more detail or examples of how to use this setting? Sources: - Pulsar docs - Java config 👍 0 button 👎 0 button 💡 Hint: Mention @runllm in the thread for followups.