Skip to content

Commit

Permalink
Ordered consumer start time fix (#424)
Browse files Browse the repository at this point in the history
When initial request delivery policy is by time
all subsequent request should still start by
sequence and reset start-time field to avoid
errors returned by server.
  • Loading branch information
mtmk authored Mar 11, 2024
1 parent 5cbe4e2 commit 92f71ce
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/NATS.Client.JetStream/NatsJSOrderedConsumer.cs
Original file line number Diff line number Diff line change
Expand Up @@ -273,6 +273,7 @@ private async Task<NatsJSConsumer> RecreateConsumer(string consumer, ulong seq,
{
OptStartSeq = seq + 1,
DeliverPolicy = ConsumerConfigDeliverPolicy.ByStartSequence,
OptStartTime = default,
};

if (consumer != string.Empty)
Expand Down

0 comments on commit 92f71ce

Please sign in to comment.