NATS Stream Discard Policy

DiscardPolicy определяет, что делать с сообщениями, когда стрим достиг одного из заданных лимитов (MaxMsgs, MaxBytes, MaxAge, MaxMsgsPerSubject). Политика применяется только если задан хотя бы один лимит.

Логику DiscardPolicy стоит рассматривать вместе с:

• лимитами стрима (что считается «переполнением»);
• RetentionPolicy (когда вообще допускается автоматическое удаление сообщений).

DiscardOld

Сообщения удаляются по принципу «удалить старые, чтобы освободить место для новых».

• При превышении любого лимита:
  • находят «лишние» сообщения (по времени, количеству или размеру);
  • сначала удаляются самые старые сообщения в стриме;
  • новые сообщения принимаются и записываются.
• Типичный вариант по умолчанию, удобен для логов, телеметрии и временных данных, где важно «последнее состояние», а не полная история.

DiscardNew

Новые сообщения отклоняются, если их запись привела бы к превышению лимита.

• При попытке записи:
  • если добавление сообщения нарушает лимиты — сообщение не сохраняется;
  • существующие сообщения в стриме не трогаются.
• Подходит для сценариев, где:
  • нельзя терять уже записанные данные;
  • лучше вернуть ошибку продьюсеру и заставить его реагировать (retry, backpressure и т.п.).

DiscardNewPerSubject

Вариант DiscardNew, применяемый на уровне каждого subject внутри одного стрима.

• Стрим может обрабатывать несколько subject (например, ORDERS.*):
  • лимит MaxMsgsPerSubject задаёт максимум сообщений на каждый subject;
  • при переполнении по конкретному subject:
    • новые сообщения для этого subject отклоняются;
    • сообщения других subject продолжают приниматься.
• Удобно, когда разные типы данных живут в одном стриме, но важно:
  • не переполнить стрим каким-то «шумным» subject;
  • при этом не удалять уже существующие сообщения по другим subject.