NATS Stream Retention Policy

RetentionPolicy — политика хранения сообщений в стриме, определяющая, когда и по какому принципу сообщения автоматически удаляются.

Основные варианты:

LimitsPolicy (по умолчанию)

Хранение по заданным лимитам стрима:

• MaxMsgs — максимум сообщений
• MaxBytes — максимум по размеру
• MaxAge — максимальный возраст
• MaxMsgsPerSubject — максимум на subject Как только первый из лимитов достигнут, старые сообщения автоматически удаляются (или новые отбрасываются — по DiscardPolicy).

WorkQueuePolicy

Поведение как у рабочей очереди (FIFO):

• каждое сообщение может быть потреблено только один раз;
• для каждого сабджекта допускается только один consumer (фильтры сабджектов не должны пересекаться);
• сообщение удаляется после успешного Ack от consumer;
• если включены лимиты (MaxMsgs, MaxBytes и т.п.), они всё равно применяются — сообщения могут удаляться и по лимитам, даже если не были доставлены.

InterestPolicy

Хранение на основе «интереса» потребителей:

• если нет ни одного consumer, сообщения удаляются сразу после публикации;
• consumer должен быть создан до публикации сообщений;
• сообщение удаляется, когда его Ack получили все consumer’ы, фильтрующие этот сабджект (по сути, как WorkQueue, но с множеством потребителей);
• лимиты (MaxMsgs, MaxBytes, MaxAge, MaxMsgsPerSubject) при наличии также продолжают работать поверх этой логики.

Общее для WorkQueuePolicy и InterestPolicy:

Даже при исчерпании попыток доставки (MaxDeliver) неподтверждённые сообщения не удаляются автоматически и требуют ручной очистки через JetStream API.