Durable Consumer Does not Consume From Last Message Per Subject about nats-server HOT 3 CLOSED

The key insight is that the consumer does not restart. It was always there.

The client who connected to the consumer went away and crashed but the consumer remained on the server.

When the crashed client - or another client - asks for messages the consumer continues where it was before. By not sending you already acknowledged messages. It does not even know you crashed.

All the start config options - start sequence, time etc - only influence the consumer once and that’s when it is created. After that the behaviour is constant. It will only ever give you unacked messages.

So probably what you want is to make a new consumer each time or use a “ordered consumer”

from nats-server.

After point 3 - the crash or restart - do you send more messages in, do those not get consumed?

The consumer will not deliver an already acked message, you cannot ask it to deliver acked messages again so that part is as designed. But after the restart the consumer should continue to deliver new messages.

from nats-server.

Thank you for your explanation. Let me provide a concrete example to clarify my understanding. Suppose I have two subjects in my stream, S1 and S2, and a durable consumer. After the consumer has acknowledged some messages but before it crashed, the consumer state is as follows (each message does not exceed the ack wait threshold, so no messages will be redelivered):

S1: a1, a2, [a3], a4, a5, a6 ...    (acked a3 message)
S2: b1, [b2], b3, b4 ...   (acked b2 message)

During the time the consumer is crashed, some new messages arrive, and the stream state becomes:

S1: a1, a2, [a3], a4, a5, a6, | a7, a8 ...    (new messages)
S2: b1, [b2], b3, b4, | b5, b6 ...   (new messages)

What I expect when the same durable consumer restarts is that it will receive the messages:

from S1: a3, a4, a5, a6, a7, a8, ....
from S2: b2, b3, b4, b5, b6 ...

So, my questions are:

1. Can the durable consumer get the last acknowledged message per subject under the DeliverLastPerSubjectPolicy delivery policy?
2. If the above condition is met, can the durable consumer receive the messages in order? (Specifically, must it be [a3, a4, a5, a6, a7] rather than [a7, a8, a3, a4, a5] or another order?)

from nats-server.