PersistentStreamPullingAgent does not Unregister itself as producer when no cunsumers left.
@benjaminpetit is already working on this.
Since Jun 16, 2022.
- Dominant language
- C#
- Stars
- 10.9k
- Forks
- 2.1k
- Avg merge
- 13h 56m
- Merged PRs (30d)
- 351
Description
I have an issue when using Azure Blob Storage for PubSubStore in combination with Azure Storage Queues for Streams.
When the last consumer is unregistered from a stream, PersistentStreamPullingAgent removes the streamId from its cache.
When the agent is shutdown it is unable to remove itself as a producer from that stream anymore because it is removed from cache
Due to this behaviour, the blobs in the PubSubStore are not removed, beacause there will always be a producer for that stream.
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Assessment
This issue has not been assessed yet.