NATS Stream RePublish

RePublish - опция стрима, при которой сервер автоматически повторно публикует каждое успешно записанное сообщение на другой subject.

Назначение

• Раздать сообщения “в реалтайме” без оверхеда consumer’а JetStream.
• Позволить подписчикам пользоваться обычной core‑подпиской NATS и одновременно иметь персистентное хранение в стриме.
• Разделить:
  • запись и долговременное хранение (JetStream);
  • высокоскоростное fan‑out по subject.

Как работает

• Сообщение публикуется продюсером в subject, попадающий в стрим.
• JetStream записывает его в стрим (с учётом всех проверок и лимитов).
• После успешной записи сервер:
  • автоматически публикует то же сообщение в destination subject;
  • добавляет служебные заголовки (метаданные JetStream).
• Подписчики могут:
  • либо читать из стрима через consumer
  • либо подписаться на destination subject как на обычный NATS‑канал.

Основные поля конфигурации

• Source

  • Необязательный фильтр по subject внутри стрима.
  • Если не задан, по умолчанию републикуются все сообщения (>).
  • Должен быть подмножеством subject’ов, привязанных к стриму.

• Destination

  • subject, в который будут републикованы сообщения.
  • Пара Source/Destination должна образовывать корректное subject mapping (совместимые wildcard’ы и уровни).

Когда использовать

• Высоконагруженные сценарии, где:
  • не хочется добавлять consumer только ради стриминга событий;
  • нужны «живые» события плюс возможность догонять историю через JetStream.
• Миграции/фан‑аут:
  • републикация в «публичный» subject для других сервисов;
  • разветвление потока из одного стрима в разные логические каналы.