Skip to content

Widhian Bramantya

coding is an art form

Menu
  • About Me
Menu
nats

Publish–Subscribe in NATS: Simple and Powerful Messaging

Posted on September 6, 2025September 6, 2025 by admin

Pub/Sub vs JetStream

The most important thing to understand is that basic pub/sub in NATS is ephemeral, while JetStream adds persistence and replay.

Basic Pub/Sub

  • Messages are delivered only to subscribers that are online at the moment.
  • If no subscriber is connected, the message is lost forever.
  • There is no way to replay past messages.

Example use case:

  • A live chat application where users in a room subscribe to chat.room1.
  • Messages are delivered instantly to everyone online.
  • If a user is offline, they never see the message.

JetStream Pub/Sub

  • Messages are stored in a stream (on disk or memory).
  • Consumers can be durable, meaning they remember their position in the stream.
  • You can replay past messages, even if you were offline when they were first published.

Example use case:

  • An e-commerce order system with events like orders.created and orders.paid.
  • A shipping service might go offline for maintenance. With JetStream, when it comes back, it can continue processing from the exact point it left off.
  • Auditors can also replay old events to analyze the order lifecycle.

Pub/Sub vs Request–Reply

NATS also supports a Request–Reply pattern, where a client sends a message and expects a response. But pub/sub is different:

  • Messages are broadcast to all subscribers.
  • There is no direct reply.
  • It’s one-to-many communication.

Limitations of Basic Pub/Sub

  • If no subscriber is online, messages are lost (unless you use JetStream for persistence).
  • Subscribers get messages in real time only.

This is why JetStream was introduced — to add persistence and replay on top of pub/sub.

Final Thoughts

Publish–Subscribe is the foundation of NATS. It’s simple but powerful, allowing you to build decoupled systems that can scale. By combining subjects with wildcards, you can design flexible messaging patterns for almost any scenario.

See also  Producers and Consumers: How Data Flows in Kafka
Pages: 1 2
Category: NATS

Leave a Reply Cancel reply

Your email address will not be published. Required fields are marked *

Linkedin

Widhian Bramantya

Recent Posts

  • Log Management at Scale: Integrating Elasticsearch with Beats, Logstash, and Kibana
  • Index Lifecycle Management (ILM) in Elasticsearch: Automatic Data Control Made Simple
  • Blue-Green Deployment in Elasticsearch: Safe Reindexing and Zero-Downtime Upgrades
  • Maintaining Super Large Datasets in Elasticsearch
  • Elasticsearch Best Practices for Beginners
  • Implementing the Outbox Pattern with Debezium
  • Production-Grade Debezium Connector with Kafka (Postgres Outbox Example – E-Commerce Orders)
  • Connecting Debezium with Kafka for Real-Time Streaming
  • Debezium Architecture – How It Works and Core Components
  • What is Debezium? – An Introduction to Change Data Capture
  • Offset Management and Consumer Groups in Kafka
  • Partitions, Replication, and Fault Tolerance in Kafka
  • Delivery Semantics in Kafka: At Most Once, At Least Once, Exactly Once
  • Producers and Consumers: How Data Flows in Kafka
  • Kafka Architecture Explained: Brokers, Topics, Partitions, and Offsets
  • Getting Started with Apache Kafka: Core Concepts and Use Cases
  • Security Best Practices for RabbitMQ in Production
  • Understanding RabbitMQ Virtual Hosts (vhosts) and Their Uses
  • RabbitMQ Performance Tuning: Optimizing Throughput and Latency
  • High Availability in RabbitMQ: Clustering and Mirrored Queues Explained

Recent Comments

  1. Playing with VPC AWS (Part 2) – Widhian's Blog on Playing with VPC AWS (Part 1): VPC, Subnet, Internet Gateway, Route Table, NAT, and Security Group
  2. Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh – Widhian's Blog on Basic Concept of ElasticSearch (Part 1): Introduction
  3. Basic Concept of ElasticSearch (Part 2): Architectural Perspective – Widhian's Blog on Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh
  4. Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh – Widhian's Blog on Basic Concept of ElasticSearch (Part 2): Architectural Perspective
  5. Basic Concept of ElasticSearch (Part 1): Introduction – Widhian's Blog on Basic Concept of ElasticSearch (Part 2): Architectural Perspective

Archives

  • October 2025
  • September 2025
  • August 2025
  • November 2021
  • October 2021
  • August 2021
  • July 2021
  • June 2021
  • March 2021
  • January 2021

Categories

  • Debezium
  • Devops
  • ElasticSearch
  • Golang
  • Kafka
  • Lua
  • NATS
  • Programming
  • RabbitMQ
  • Redis
  • VPC
© 2025 Widhian Bramantya | Powered by Minimalist Blog WordPress Theme