JetStream

Detailed documentation on the NATS JetStream component

配置

要设置 JetStream pubsub,请创建一个类型为 pubsub.jetstream 的组件。 请参阅本指南,了解如何创建和应用 pubsub 配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: jetstream-pubsub
  namespace: default
spec:
  type: pubsub.jetstream
  version: v1
  metadata:
  - name: natsURL
    value: "nats://localhost:4222"
  - name: name
    value: "connection name"
  - name: durableName
    value: "consumer durable name"
  - name: queueGroupName
    value: "queue group name"
  - name: startSequence
    value: 1
  - name: startTime # in Unix format
    value: 1630349391
  - name: deliverAll
    value: false
  - name: flowControl
    value: false

元数据字段规范

字段 必填 详情 示例
natsURL NATS 服务器地址 URL nats://localhost:4222
name NATS 连接名称 "my-conn-name"
durableName Durable name "my-durable"
queueGroupName 队列组名称 "my-queue"
startSequence 起始编号 1
startTime Unix 时间戳格式的开始时间 1630349391
deliverAll 将全部交付设置为 重播策略 true
flowControl 流量控制 true

创建NATS服务器


您可以使用 Docker 在本地启用 JetStream 运行 NATS 服务器:

docker run -d -p 4222:4222 nats:latest -js

然后,您可以使用 localhost:4222 与服务器进行交互。


使用 [helm](https://github. com/nats-io/k8s/tree/main/helm/charts/nats#jetstream)在 Kubernetes 上安装 NATS JetStream:

helm repo add nats https://nats-io.github.io/k8s/helm/charts/
helm install my-nats nats/nats

default 命名空间安装单进程NATS服务。 要与NATS进行交互,请使用以下方法找到服务:kubectl get svc my-nats.

创建 JetStream

为特定主题创建 NATS JetStream 至关重要。 例如,对于本地运行的 NATS 服务器,请使用:

nats -s localhost:4222 stream add myStream --subjects mySubject

相关链接