如何通过 Apache Pulsar 使用 IBM® App Connect

Apache Pulsar 是一个云原生消息传递和事件流平台,支持高吞吐量、低延迟和实时数据处理。

可用性:
  • App Connect 连接器
  • IBM App Connect in containers Designer 实例中的本地连接器(持续交付版本)容器中的本地连接器(持续交付版本)13.0.4.0-r1 或更高版本

支持的产品和应用程序接口版本

如需了解此连接器支持哪些产品和 API 版本,请参阅 IBM 支持页面上的 “详细系统要求”

连接至 Apache Pulsar

填写您在 App Connect 设计器连接 > 应用程序和 API 页面(以前称为目录页面) 或流程编辑器中看到的连接字段。 如有必要,请与 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 之前,请注意以下事项:

  • 您可以在 App Connect Designer应用程序和 API 页面上查看可用的触发事件和操作列表。

    对于某些应用,事件和操作取决于环境以及连接器是否支持可配置事件和动态发现操作。 如果应用程序支持可配置事件,您会在事件列表下看到“ 显示更多可配置事件” 链接。 如果应用程序支持动态发现操作,您会在操作列表下看到 “显示更多” 链接。

  • 如果某个应用程序使用多个账户,不同账户为该应用程序选择操作时显示的字段集可能不同。 在流程编辑器中,某些应用程序总是为某个操作提供一组经过编辑的静态字段。 其他应用程序使用动态发现功能来检索所连接实例上配置的字段集。 例如,如果一个应用程序的两个实例有两个账户,第一个账户可能会使用可立即使用的设置。 不过,第二个账户可能配置了额外的自定义字段。

岗位连接注意事项

连接 Apache Pulsar 后,请注意以下事项。
  • 切换到高级模式
    • 创建新主题或订阅。
    • 在发布或检索信息以查看或配置其他属性时。

事件和行动

Apache 脉冲星活动

这些事件用于处理本应用程序中的更改,这些更改会触发流程开始完成流程中的操作。

事件 描述
新消息 检测 Apache Pulsar 中的新信息

Apache 脉冲星行动

您的流程将在此应用程序上完成这些操作。

对象 操作 描述
信息发布 向主题发布信息 Apache Pulsar 中的主题发布消息
信息订阅 从订阅中读取邮件 检索与 Apache Pulsar 中的订阅相关联的邮件