merlimat commented on a change in pull request #1352: Delete inactive
subscriptions automatically
URL: https://github.com/apache/incubator-pulsar/pull/1352#discussion_r179603205
##########
File path:
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
##########
@@ -89,6 +89,11 @@
private int messageExpiryCheckIntervalInMinutes = 5;
// How long to delay rewinding cursor and dispatching messages when active
consumer is changed
private int activeConsumerFailoverDelayTimeMillis = 1000;
+ // How long to delete inactive subscriptions from last consuming
+ // When it is 0, inactive subscriptions are not deleted automatically
+ private long subscriptionExpirationTimeMinutes = 0;
+ // How frequently to proactively check and purge expired subscription
+ private long subscriptionExpiryCheckIntervalInMinutes = 5;
Review comment:
I think that more than "last consume time" it should be more like "timestamp
of last consumer disconnecting from a particular subscription"
----------------------------------------------------------------
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:
us...@infra.apache.org
With regards,
Apache Git Services
