Kafka 软件包 中的连接 操作 - Kafka 软件包 中的 连接 操作 使您能够使用受支持的安全协议对 Apache Kafka broker 进行身份验证，并建立一个后续 Kafka 操作 可使用的命名会话。

Automation 360

Kafka 软件包 中的连接 操作 使您能够使用受支持的安全协议对 Apache Kafka broker 进行身份验证，并建立一个后续 Kafka 操作 可使用的命名会话。

先决条件

  • Kafka broker 引导服务器地址采用 host:port 格式。 请参阅 Kafka: Quick Start。
  • 身份验证凭据根据所选的安全协议进行准备：请参阅 Kafka: Security Overview
  • Bot Agent 主机可以通过已配置的端口连接到 Kafka broker（明文默认为 9092，SSL 默认为 9093）。如果您在 Kafka 软件包 中使用 API 任务，请确保您拥有所需的许可证和权限。 请参阅 API 任务。

设置

使用连接 操作 打开与 Apache Kafka broker 的已认证会话。 在工作流中，您必须在任何其他 Kafka 操作 之前调用连接 操作。 始终将此 操作 与工作流末尾的断开连接 操作 配对，以释放 broker 资源。

  • 引导服务器： 以 host:port 格式输入一个或多个 broker 地址，多个地址之间用逗号分隔。 例如，broker1.example.com:9092, broker2.example.com:9092。
  • 安全协议： 选择以下安全协议之一：
    • 明文： 用于开发、测试或不使用加密或身份验证的内部网络。
    • SASL 明文： 在受信任且隔离的网络上使用此选项，不加密。
      • 选择以下 SASL 机制之一：
        • PLAIN： 客户端将凭据以明文发送到 broker。
        • SCRAM_SHA_256： 客户端使用 256 位哈希机制发送凭据。 比 PLAIN SASL 机制更安全。
        • SCRAM_SHA_512： 客户端使用 512 位哈希机制发送凭据。 最安全的 SASL 机制。
      • 选择下列选项之一以指定用户名：
        • 凭据： 允许您使用 Credential Vault 中存储的用户名。
        • 变量： 使您能够使用存储在变量中的用户名。
        • 不安全字符串： 允许您手动输入用户名。
      • 选择以下一个选项，以指定密码：
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
    • SASL SSL： 在需要使用 SASL 身份验证同时进行身份验证和数据保护的实际正式环境中使用此选项。
      • 选择以下 SASL 机制之一：
        • PLAIN： 客户端将凭据以明文发送到 broker。
        • SCRAM_SHA_256： 客户端使用 256 位哈希机制发送凭据。 比 PLAIN SASL 机制更安全。
        • SCRAM_SHA_512： 客户端使用 512 位哈希机制发送凭据。 最安全的 SASL 机制。
      • 选择下列选项之一以指定用户名：
        • 凭据： 允许您使用 Credential Vault 中存储的用户名。
        • 变量： 使您能够使用存储在变量中的用户名。
        • 不安全字符串： 允许您手动输入用户名。
      • 选择以下一个选项，以指定密码：
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
      • 选择以下任一选项指定信任库文件的位置：
        • 变量： 用于指定包含文件位置的文件变量。
        • Control Room 文件： 用于选择 Control Room 文件夹中可用的文件。
        • 桌面文件： 用于选择设备上可用的文件。
      • 选择以下一个选项，以指定信任库密码：
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
    • SSL： 在需要使用客户端证书进行身份验证和数据保护的实际正式环境中使用此选项。
      • 选择以下选项之一以指定密钥库文件的位置：
        • 变量： 用于指定包含文件位置的文件变量。
        • Control Room 文件： 用于选择 Control Room 文件夹中可用的文件。
        • 桌面文件： 用于选择设备上可用的文件。
      • 选择以下一个选项，以指定密钥库密码：
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
      • 选择以下选项之一以指定密钥库文件的位置：
        • 变量： 用于指定包含文件位置的文件变量。
        • Control Room 文件： 用于选择 Control Room 文件夹中可用的文件。
        • 桌面文件： 用于选择设备上可用的文件。
      • 指定以下选项以指定密钥库密码。
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
      • （可选）指定以下选项以指定密钥密码。
        • 凭据： 允许您使用存储在 Credential Vault 中的密码。
        • 变量： 使您能够使用存储在变量中的密码。
        • 不安全字符串： 允许您手动输入密码。
  • Kafka 会话： 选择以下一个选项，以指定如何存储 Kafka 会话：
    • 本地会话： 指定一个只能在当前自动化中使用的会话名称。
    • 全局会话： 指定一个可在多个自动化中使用的会话名称，例如父自动化和子自动化。
      注： 父和子自动化应具有相同的 软件包 版本。
    • 变量： 指定一个可用于与其他子自动化共享该会话的会话变量。