The documentation you are viewing is for Dapr v1.5 which is an older version of Dapr. For up-to-date documentation, see the latest version.

Pulsar

关于Pulsar pubsub组件的详细文档

配置

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

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pulsar-pubsub
  namespace: default
spec:
  type: pubsub.pulsar
  version: v1
  metadata:
  - name: host
    value: "localhost:6650"
  - name: enableTLS
    value: "false"

元数据字段规范

字段 必填 详情 示例
host Y Pulsar broker. 地址， 默认值是 "localhost:6650" "localhost:6650"
enableTLS N 启用TLS 默认值为 "false" "true", "false"

延迟队列

当调用 Pulsar 发布/订阅时，在请求 url 中使用 metadata 查询参数来提供一个可选的延迟队列时可行的。

可选参数的名称为 metadata.deliverAt 或 metadata.deliverAfter

  • deliverAt: 延迟消息以在指定的时间投递 (RFC3339 格式)，例如 "2021-09-01T10:00:00Z"
  • deliverAfter:延迟消息在指定的时间后进行投递，例如 "4h5m3s"

示例:

curl -X POST http://localhost:3500/v1.0/publish/myPulsar/myTopic?metadata.deliverAt='2021-09-01T10:00:00Z' \
  -H "Content-Type: application/json" \
  -d '{
        "data": {
          "message": "Hi"
        }
      }'

或者

curl -X POST http://localhost:3500/v1.0/publish/myPulsar/myTopic?metadata.deliverAfter='4h5m3s' \
  -H "Content-Type: application/json" \
  -d '{
        "data": {
          "message": "Hi"
        }
      }'

创建 Pulsar 实例


docker run -it \
  -p 6650:6650 \
  -p 8080:8080 \
  --mount source=pulsardata,target=/pulsar/data \
  --mount source=pulsarconf,target=/pulsar/conf \
  apachepulsar/pulsar:2.5.1 \
  bin/pulsar standalone

请参考以下Helm chart文档。

相关链接