{% extends "base.html" %} {% block title %}Central — Consumers{% endblock %} {% block content %}

Consumers

JetStream consumers across all registered streams. A consumer with high Pending and zero Waiting has accumulated unacknowledged messages and has no active subscriber — it is safe to delete if it is not a central-owned consumer.

{% for stream in streams %}
{{ stream.stream }}
{% if stream.error %}

({{ stream.error }})

{% elif stream.consumers %}
{% for c in stream.consumers %} {% endfor %}
Name Pending Ack Pending Redelivered Waiting Delivered Confirmed Created Action
{{ c.name }} {{ c.num_pending if c.num_pending is not none else '—' }} {{ c.num_ack_pending if c.num_ack_pending is not none else '—' }} {{ c.num_redelivered if c.num_redelivered is not none else '—' }} {{ c.num_waiting if c.num_waiting is not none else '—' }} {{ c.delivered if c.delivered is not none else '—' }} {{ c.acked if c.acked is not none else '—' }} {{ c.created.isoformat() if c.created else '—' }} {% if c.protected %} central-owned {% else %}
{% endif %}
{% else %}

(no consumers)

{% endif %}
{% endfor %}

Legend: Pending = messages not yet delivered to this consumer; Ack Pending = delivered but not yet acknowledged; Waiting = active pull requests from a live subscriber; Delivered = total messages this consumer has received from the stream (lifetime counter); Confirmed = total messages this consumer has acknowledged (processed) — these are consumer-level counters (the subscriber got/acked it) and are NOT confirmation that the message reached a mesh device. A consumer with high Pending and zero Waiting is abandoned — no subscriber is pulling from it and messages are piling up. Consumers marked central-owned (archive-*) are managed by central and cannot be deleted here.

{% endblock %}