Skip to content

Fix acked messages being sometimes redelivered during rollouts #5419

Merged
derekcollison merged 5 commits intomainfrom
double-ack-redelivery
May 15, 2024
Merged

Fix acked messages being sometimes redelivered during rollouts #5419
derekcollison merged 5 commits intomainfrom
double-ack-redelivery

Conversation

@wallyqs
Copy link
Copy Markdown
Member

@wallyqs wallyqs commented May 15, 2024

Under some conditions during a rollout, messages that were already acked or double acked (ack sync), would have been redelivered to a consumer. Also includes fixes for TestJetStreamClusterScaleConsumer for consumer rescaling.

wallyqs and others added 5 commits May 13, 2024 10:29
Signed-off-by: Waldemar Quevedo <wally@nats.io>
Signed-off-by: Derek Collison <derek@nats.io>
…plicated ack and if we are still the leader.

Signed-off-by: Derek Collison <derek@nats.io>
…il out pch.

This allows subsequent scale back up to recreate that go routine.

Signed-off-by: Derek Collison <derek@nats.io>
Signed-off-by: Derek Collison <derek@nats.io>
@wallyqs wallyqs requested a review from a team as a code owner May 15, 2024 01:06
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

@derekcollison derekcollison merged commit 4c8d2bb into main May 15, 2024
@derekcollison derekcollison deleted the double-ack-redelivery branch May 15, 2024 02:00
neilalexander pushed a commit that referenced this pull request May 16, 2024
Under some conditions during a rollout, messages that were already acked
or double acked (ack sync), would have been redelivered to a consumer.
Also includes fixes for `TestJetStreamClusterScaleConsumer` for consumer
rescaling.

---------

Signed-off-by: Waldemar Quevedo <wally@nats.io>
Signed-off-by: Derek Collison <derek@nats.io>
Co-authored-by: Derek Collison <derek@nats.io>
wallyqs added a commit that referenced this pull request May 16, 2024
Under some conditions during a rollout, messages that were already acked
or double acked (ack sync), would have been redelivered to a consumer.
Also includes fixes for `TestJetStreamClusterScaleConsumer` for consumer
rescaling.

---------

Signed-off-by: Waldemar Quevedo <wally@nats.io>
Signed-off-by: Derek Collison <derek@nats.io>
Co-authored-by: Derek Collison <derek@nats.io>
neilalexander added a commit that referenced this pull request May 16, 2024
Includes the following:

* #5405
* #5406
* #5413
* #5419
* #5420
* #5426
* #5427
* #5428

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