NATS

Consumers Commands

Create consumers to read from JetStream streams. Configure delivery policies, acknowledgment strategies, and redelivery for reliable message processing.

7 commands

Pro Tips

Create durable consumer: 'nats consumer add ORDERS PROCESSOR --filter orders.new --ack explicit'.

Consume interactively: 'nats consumer next ORDERS PROCESSOR --count 10' fetches the next 10 messages.

Check lag: 'nats consumer info ORDERS PROCESSOR' shows pending messages and delivery stats.

Common Mistakes

Without explicit ack, messages redeliver after the ack-wait timeout. Always acknowledge processed messages.

Deleting a consumer loses its position tracking. Remaining messages stay in the stream but position resets.

Commands

Create pull consumer

$ nats consumer add ORDERS DISPATCH --pull --ack explicit --max-deliver 20

Create pull-based consumer with retry limits.

Create push consumer

$ nats consumer add ORDERS MONITOR --target monitor.orders --ack none

Create push consumer that sends to target subject.

List consumers

$ nats consumer ls ORDERS

List consumers for a stream.

Consumer info

$ nats consumer info ORDERS DISPATCH

View consumer configuration and state.

Get next message

$ nats consumer next ORDERS DISPATCH

Retrieve next available message from pull consumer.

Pause consumer

$ nats consumer pause ORDERS DISPATCH

Temporarily suspend consumer (NATS 2.11+).

Resume consumer

$ nats consumer resume ORDERS DISPATCH

Resume paused consumer.