Support updating PCGroup filters dynamically#45
Conversation
|
Hi and thanks for the contribution, however at this point I'm not convinced this would be a good idea to merge. It certainly wasn't the initial intention to be able to modify the filters of an existing consumer group. While on the face of it I don't see an issue with adding a filter, there's a fundamental issue with orphaned messages on filter delete. Messages already sourced (under a now-removed filter) stay in the work-queue indefinitely. If I may ask what is the use case? Can it not be done with for example deleting and re-creating the consumer group? |
|
Thanks for your reply. |
This PR adds runtime partitioning-filter management for Elastic PCGroups and fixes NatsPcgPartitioningFilter value semantics.
Changes
Added:
AddPcgElasticFiltersAsync(...)
DeletePcgElasticFiltersAsync(...)
NatsPcgPartitioningFilter now compares by value (Filter + PartitioningWildcards) via custom Equals/GetHashCode.