You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/02/18 17:50:36 UTC

[GitHub] [pulsar-client-go] frankjkelly edited a comment on issue #468: Add Support for NonDurable subscriptions

frankjkelly edited a comment on issue #468:
URL: https://github.com/apache/pulsar-client-go/issues/468#issuecomment-781511179


   Thanks - I guess that's not what I think we're seeing using the 0.3.0 Go Client library with Pulsar 2.6.1
   
   In the image below taken from our Pulsar Grafana dashboard hopefully you can see our Consumers (on the `cogito-dialog\wav` namespace are short-lived) but the count of subscriptions on that namespace lasts much longer and the count of subscribers only goes down at the 1 hour mark since we have set a subscription expiration time on that namespace (largely so we can allow the ledger to rollover and disk to be reclaimed).
   
   ![image](https://user-images.githubusercontent.com/62910985/108396153-8901a280-71e4-11eb-86e1-cf09c03d14cf.png)
   
   Here is how we have configured our consumer
   ```
   	consumer, err := p.client.Subscribe(pulsar.ConsumerOptions{
   		Topic:                       topic,
   		SubscriptionName:            subscriptionName,
   		SubscriptionInitialPosition: pulsar.SubscriptionPositionEarliest,
   		Type:                        pulsar.Exclusive,
   	})
   ```
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org