Skip to content

[FIXED] Propagate stream interest policy changes to consumers in all cases#6995

Merged
neilalexander merged 1 commit intomainfrom
neil/consumerretention
Jun 20, 2025
Merged

[FIXED] Propagate stream interest policy changes to consumers in all cases#6995
neilalexander merged 1 commit intomainfrom
neil/consumerretention

Conversation

@neilalexander
Copy link
Copy Markdown
Member

When switching from limits to interest, we were propagating this update to consumers, but we weren't doing so when switching from interest to limits. This would leave consumers running with o.retention set to InterestPolicy, continuing to run checkStateForInterestStream etc even after the stream itself had moved back to the LimitsPolicy.

Signed-off-by: Neil Twigg neil@nats.io

@neilalexander neilalexander requested a review from a team as a code owner June 20, 2025 15:45
@neilalexander neilalexander force-pushed the neil/consumerretention branch from 5ed4daa to 06467f9 Compare June 20, 2025 15:47
Copy link
Copy Markdown
Member

@derekcollison derekcollison left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM - but need staticcheck fix on test first.

@neilalexander
Copy link
Copy Markdown
Member Author

Yep, just fixed it.

Copy link
Copy Markdown
Member

@derekcollison derekcollison left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@neilalexander neilalexander merged commit b391ee9 into main Jun 20, 2025
89 of 92 checks passed
@neilalexander neilalexander deleted the neil/consumerretention branch June 20, 2025 16:28
@wallyqs wallyqs changed the title Propagate stream interest policy changes to consumers in all cases [FIXED] Propagate stream interest policy changes to consumers in all cases Jun 24, 2025
neilalexander added a commit that referenced this pull request Jun 24, 2025
Includes the following:

- #6990
- #6967
- #6995
- #6999
- #7001

Signed-off-by: Neil Twigg <neil@nats.io>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants