NATS Consumer

Консьюмер (consumer) в JetStream — это состояние‑зависимое «представление» стрима: он выбирает нужное подмножество сообщений из стрима и ведёт учёт, какие сообщения были доставлены и подтверждены (ack), обеспечивая доставку минимум один раз (at-least-once).

Основные виды консьюмеров:

• По способу получения сообщений:

  • Push — сервер сам пушит сообщения на указанный subject.
  • Pull — клиент сам запрашивает батчи сообщений по мере готовности.

• По жизненному циклу:

  • Durable — с именем, состояние (offset и пр.) сохраняется, можно возобновить чтение.
  • Ephemeral — без имени, состояние только в памяти, удаляется после периода неактивности.

• По порядку/назначению:

  • Ordered consumer (упорядоченный) — специальный тип для последовательного чтения:
    • всегда ephemeral
    • без ack
    • автоматический флоу‑контроль
    • нет балансировки нагрузки.