JetStream 有一个 /jsz HTTP 端点和可用的告警信息。
JetStream 会发布一系列告警信息,这些信息可以告知操作人员有关流(Streams)的健康状况和状态。这些告警信息发布到正常的 NATS 主题中,位于 $JS.EVENT.ADVISORY.> 中,如果需要,可以将这些告警信息存储在 JetStream 流中。
命令 nats event --js-advisory 可以在控制台上查看所有这些事件。Golang 包 jsm.go 可以消费并呈现这些事件,并为每种事件提供相应的数据类型。
所有这些事件都有描述它们的 JSON Schemas,可以通过 CLI 使用 nats schema show <schema kind> 命令查看。
| Description | Subject | Kind |
|---|---|---|
| API interactions | $JS.EVENT.ADVISORY.API |
io.nats.jetstream.advisory.v1.api_audit |
| Stream CRUD operations | $JS.EVENT.ADVISORY.STREAM.CREATED.<STREAM> |
io.nats.jetstream.advisory.v1.stream_action |
| Consumer CRUD operations | $JS.EVENT.ADVISORY.CONSUMER.CREATED.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.consumer_action |
Snapshot started using nats stream backup |
$JS.EVENT.ADVISORY.STREAM.SNAPSHOT_CREATE.<STREAM> |
io.nats.jetstream.advisory.v1.snapshot_create |
| Snapshot completed | $JS.EVENT.ADVISORY.STREAM.SNAPSHOT_COMPLETE.<STREAM> |
io.nats.jetstream.advisory.v1.snapshot_complete |
Restore started using nats stream restore |
$JS.EVENT.ADVISORY.STREAM.RESTORE_CREATE.<STREAM> |
io.nats.jetstream.advisory.v1.restore_create |
| Restore completed | $JS.EVENT.ADVISORY.STREAM.RESTORE_COMPLETE.<STREAM> |
io.nats.jetstream.advisory.v1.restore_complete |
| Consumer maximum delivery reached | $JS.EVENT.ADVISORY.CONSUMER.MAX_DELIVERIES.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.max_deliver |
| Message delivery naked using AckNak | $JS.EVENT.ADVISORY.CONSUMER.MSG_NAKED.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.nak |
| Message delivery terminated using AckTerm | $JS.EVENT.ADVISORY.CONSUMER.MSG_TERMINATED.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.terminated |
| Message acknowledged in a sampled Consumer | $JS.EVENT.METRIC.CONSUMER.ACK.<STREAM>.<CONSUMER> |
io.nats.jetstream.metric.v1.consumer_ack |
| Clustered Stream elected a new leader | $JS.EVENT.ADVISORY.STREAM.LEADER_ELECTED.<STREAM> |
io.nats.jetstream.advisory.v1.stream_leader_elected |
| Clustered Stream lost quorum | $JS.EVENT.ADVISORY.STREAM.QUORUM_LOST.<STREAM> |
io.nats.jetstream.advisory.v1.stream_quorum_lost |
| Clustered Consumer elected a new leader | $JS.EVENT.ADVISORY.CONSUMER.LEADER_ELECTED.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.consumer_leader_elected |
| Clustered Consumer lost quorum | $JS.EVENT.ADVISORY.CONSUMER.QUORUM_LOST.<STREAM>.<CONSUMER> |
io.nats.jetstream.advisory.v1.consumer_quorum_lost |
NATS Surveyor 系统最初支持将 JetStream 指标传递到 Prometheus,未来还将添加更多仪表板功能,直至最终发布。