Apache Pulsar 是一个云原生消息传递和事件流平台,支持高吞吐量、低延迟和实时数据处理。
可用性:
- App Connect 连接器
容器中的本地连接器(持续交付版本)13.0.4.0-r1 或更高版本
支持的产品和应用程序接口版本
如需了解此连接器支持哪些产品和 API 版本,请参阅 IBM 支持页面上的 “详细系统要求”。
连接至 Apache Pulsar
填写您在 App Connect 设计器 页面(以前称为目录页面) 或流程编辑器中看到的连接字段。 如有必要,请与 Apache Pulsar 管理员合作获取这些值。
Apache Pulsar 授权类型和连接字段:
- 基本
- 账户名称 :为您的账户提供一个有意义的名称,以便您识别该账户。
- Broker URL (主机名和端口) :Broker URL 是用于发送和接收信息的 Apache Pulsar 代理或代理的地址,通常格式为 pulsar://host:port。 支持多个代理,可将其指定为以逗号分隔的列表(例如, host1:port1,host2:port2)。若要通过 SSL 连接,请改用 pulsar+ssl:// 。
- Admin URL (主机名和端口) :管理 URL 是 Apache Pulsar 管理 REST API 的 URL ,用于执行管理操作,通常格式为 http://host:port (如 http://127.0.0.1:8080 )或 https://host:port (如 https://127.0.0.1:8080 )。
- 用户名 : Apache Pulsar 帐户的唯一标识符,用于身份验证和访问控制。
- 密码 :用于 Apache Pulsar 身份验证的安全凭证。
- 服务器 CA 证书 :请以 PEM 格式指定用于服务器端身份验证的证书颁发机构 (CA) 证书。 TLS ( mTLS )的双向身份验证需要服务器CA证书和客户端证书。
- 租户 :管理 Apache Pulsar 命名空间和资源的专用空间。
- 模式注册 :指定后,模式验证将应用于启用模式的主题。 如果未指定,则跳过模式验证。
- 专用网络连接 : 选择用于连接到您的专用网络的专用网络代理名称。 App Connect 的名称。 该列表由在专用网络页面上创建的专用网络代理名称填充。 有关更多信息,请参阅连接到专用网络。
- 基本 JWT
- 账户名称 :为您的账户提供一个有意义的名称,以便您识别该账户。
- Broker URL (主机名和端口) :Broker URL 是用于发送和接收信息的 Apache Pulsar 代理或代理的地址,通常格式为 pulsar://host:port。 支持多个代理,可将其指定为以逗号分隔的列表(例如, host1:port1,host2:port2)。若要通过 SSL 连接,请改用 pulsar+ssl:// 。
- Admin URL (主机名和端口) :管理 URL 是 Apache Pulsar 管理 REST API 的 URL ,用于执行管理操作,通常格式为 http://host:port (如 http://127.0.0.1:8080 )或 https://host:port (如 https://127.0.0.1:8080 )。
- 服务器 CA 证书 :请以 PEM 格式指定用于服务器端身份验证的证书颁发机构 (CA) 证书。 TLS ( mTLS )的双向身份验证需要服务器CA证书和客户端证书。
- 租户 :管理 Apache Pulsar 命名空间和资源的专用空间。
- 有效载荷主题 :可提供字符串形式的角色名称(用作 "子 "声明)或包含 JWT 声明(如 { sub: 'admin', iat: <timestamp>, exp: <timestamp>
} )的 JSON 对象,以配置令牌行为。
- 私钥 :用于使用非对称加密技术安全签署 JWT 的加密密钥。 提供的私钥应采用标准 PEM 格式。
- 秘钥 :共享密钥,用于使用对称加密签署和验证 JWT。 提供的密钥应采用标准 Base64 格式。
- 模式注册 :指定后,模式验证将应用于启用模式的主题。 如果未指定,则跳过模式验证。
- 专用网络连接 : 选择用于连接到您的专用网络的专用网络代理名称。 App Connect 的名称。 该列表由在专用网络页面上创建的专用网络代理名称填充。 有关更多信息,请参阅连接到专用网络。
- MTLS
- 账户名称 :为您的账户提供一个有意义的名称,以便您识别该账户。
- Broker URL (主机名和端口) :Broker URL 是用于发送和接收信息的 Apache Pulsar 代理或代理的地址,通常格式为 pulsar://host:port。 支持多个代理,可将其指定为以逗号分隔的列表(例如, host1:port1,host2:port2)。若要通过 SSL 连接,请改用 pulsar+ssl:// 。
- Admin URL (主机名和端口) :管理 URL 是 Apache Pulsar 管理 REST API 的 URL ,用于执行管理操作,通常格式为 http://host:port (如 http://127.0.0.1:8080 )或 https://host:port (如 https://127.0.0.1:8080 )。
- 客户端密钥 :用于客户端身份验证的用户生成的私钥,格式为 PEM。
- 客户端证书 :用于客户端身份验证的用户生成的客户端证书,格式为 PEM。 TLS ( mTLS )的双向身份验证需要客户端证书和服务器CA证书。
- 服务器 CA 证书 :请以 PEM 格式指定用于服务器端身份验证的证书颁发机构 (CA) 证书。 TLS ( mTLS )的双向身份验证需要服务器CA证书和客户端证书。
- 租户 :管理 Apache Pulsar 命名空间和资源的专用空间。
- 模式注册 :指定后,模式验证将应用于启用模式的主题。 如果未指定,则跳过模式验证。
- 专用网络连接 : 选择用于连接到您的专用网络的专用网络代理名称。 App Connect 的名称。 该列表由在专用网络页面上创建的专用网络代理名称填充。 有关更多信息,请参阅连接到专用网络。
要获取 Apache Pulsar 的连接参数,请参阅《 获取 Apache Pulsar的连接参数 》。
要首次从 App Connect Designer 应用程序和 API 页面连接到 Apache Pulsar 端点,请展开 Apache Pulsar ,然后单击连接。 更多信息,请参阅管理账户。
提示:在流程中使用 App Connect 中创建的账户之前,请将其重命名为有意义的名称,以便于识别。 要在 "应用程序和 API " 页面上重命名账户,请选择账户,打开其选项菜单 (⋮),然后单击 " 重命名账户 "。
一般注意事项
在使用 App Connect Designer 和 Apache Pulsar 之前,请注意以下事项:
岗位连接注意事项
连接
Apache Pulsar 后,请注意以下事项。
- 切换到高级模式 :
- 创建新主题或订阅。
- 在发布或检索信息以查看或配置其他属性时。
事件和行动
这些事件用于处理本应用程序中的更改,这些更改会触发流程开始完成流程中的操作。
| 事件 |
描述 |
| 新消息 |
检测 Apache Pulsar 中的新信息 |
您的流程将在此应用程序上完成这些操作。
| 对象 |
操作 |
描述 |
| 信息发布 |
向主题发布信息 |
向 Apache Pulsar 中的主题发布消息 |
| 信息订阅 |
从订阅中读取邮件 |
检索与 Apache Pulsar 中的订阅相关联的邮件 |