codelipenghui 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_r213189938
##########
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:
Yeah, it's already have a enum in BacklogQuota named RetentionPolicy
```java
public static enum RetentionPolicy {
/** Policy which holds producer's send request until the resource
becomes available (or holding times out) */
producer_request_hold,
/** Policy which throws javax.jms.ResourceAllocationException to the
producer */
producer_exception,
/** Policy which evicts the oldest message from the slowest
consumer's backlog */
consumer_backlog_eviction,
}
```
----------------------------------------------------------------
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
