Suhas Karanth
06/25/2025, 7:24 AMRunLLM
06/25/2025, 7:24 AMmaxConsumersPerSubscription and maxSubscriptionsPerTopic are set high enough for your expected concurrency (source).
- Unacknowledged message limits: Tune maxUnackedMessagesPerConsumer and maxUnackedMessagesPerSubscription to avoid broker memory issues, especially with Key_Shared (source, source).
- Retention policy: By default, Pulsar deletes acknowledged messages and topics with no subscriptions. Set a retention policy if you need to retain data after consumption or when no subscriptions exist (source, source).
- Inactive topic deletion: Consider disabling or tuning brokerDeleteInactiveTopicsEnable and related settings to prevent unexpected topic deletion (source, source).
- Receiver queue size: For fine-grained control over consumer memory and throughput, adjust receiverQueueSize per consumer (source).
Would you like more detail on any of these configuration areas?
Sources:
- pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
- Pulsar as a message queue
- https://github.com/apache/pulsar/issues/21045
- https://pulsar.apache.org/docs/3.2.x/cookbooks-retention-expiry
- https://docs.streamnative.io/docs/migrating-to-streamnative#Manage%20Billing 👍 0 button 👎 0 button 💡 Hint: Mention @runllm in the thread for followups.