Use Azure BlobStore offloader with Pulsar 安装 前提条件 步骤 Note Configuration Note 配置 Azure BlobStore offloader driver Bucket (必选) 示例 身份验证 (必选) 读取/写入的数据块大小 配置 Azure BlobStore ...

集群资源 准备新集群 pulsar-admin REST API Java 初始化集群元数据 不能通过 REST API 或者 Java admin API 初始化集群元数据。 获取配置 pulsar-admin REST API Java 更新 pulsar-admin REST Java 删除 pulsar-admin RE...

Managing Namespaces 命名空间资源 创建命名空间 获取策略 获取命名空间列表 删除命名空间 配置复制集群 设置复制集群 获取复制集群 配置 backlog quota 策略 设置 backlog quota 策略 获取 backlog quota 策略 移除 backlog quota 策略 配置持久化策略 设置持久化...

Pulsar Go client 安装 安装 go 工具包 连接 URL 创建客户端 Producers Producer operations 生产者示例 如何在生产者中使用消息路由器 How to use schema interface in producer 如何在生产者中使用相应的延迟 Producer 配置 Consumer...

概念 Pulsar 消息 Topic Partitioned Topic Namespace Namespace Bundle Tenant Subscription Pub-Sub Producer Consumer Reader Cursor Acknowledgment (ack) Negative Acknowledgme...

Pulsar Terminology Concepts Pulsar Message Topic Partitioned Topic Namespace Namespace Bundle Tenant Subscription Pub-Sub Producer Consumer Reader Cursor Acknowledgmen...

Connector Admin CLI sources create 用法 选项 update 用法 选项 delete 用法 选项 get 用法 选项 status 用法 选项 list 用法 选项 stop 用法 选项 start 用法 选项 restart 用法 选项 local...

Client authentication using OAuth 2.0 access tokens 配置认证提供者 认证类型 Note 客户端凭据 典型的 OAuth2 请求映射 客户端配置 Java C++ client Go client Python client CLI 配置 pulsar-admin pulsar-clie...

Deploying a Pulsar cluster on AWS using Terraform and Ansible Requirements and setup Installation SSH setup Create AWS resources using Terraform Apply a non-default configuratio...

Deploying a Pulsar cluster on AWS using Terraform and Ansible Requirements and setup 安装 SSH setup Create AWS resources using Terraform Apply a non-default configuration What is...