merlimat commented on a change in pull request #2460: Add backlog quota
retention policy to server config.
URL: https://github.com/apache/incubator-pulsar/pull/2460#discussion_r213179479
##########
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
##########
@@ -86,6 +86,11 @@
private int backlogQuotaCheckIntervalInSeconds = 60;
// Default per-topic backlog quota limit
private long backlogQuotaDefaultLimitGB = 50;
+ //Default backlog quota retention policy. Default is producer_request_hold
+ //'producer_request_hold' Policy which holds producer's send request until
the resource becomes available (or holding times out)
+ //'producer_exception' Policy which throws
javax.jms.ResourceAllocationException to the producer
+ //'consumer_backlog_eviction' Policy which evicts the oldest message from
the slowest consumer's backlog
+ private String backlogQuotaRetentionPolicy = "producer_request_hold";
Review comment:
This could be set with the enum so that we can validate the value when
loading the config file.
Also, similar to the `backlogQuotaDefaultLimitGB` this config var could be
called `backlogQuotaDefaultRetentionPolicy`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on 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
