Kafka 目标

要配置连接器，请执行以下操作：

1. 在连接中单击创建连接。

2. 选择 Kafka 目标连接器，然后提供以下设置：

数据目标

数据网关

将数据移动到 Amazon MSK 时，只有当 Amazon MSK 无法从 Qlik Cloud 访问，并且只能使用私有链接访问时（例如，如果它位于虚拟专用云中），才需要 数据移动网关。如果是这种情况，请选择要通过其访问目标数据库的 数据移动网关。根据您的使用情况，这将和从数据源移动数据时部署的 数据移动网关 相同，或者与之不同。

如果您要将数据移动到可从 Qlik Cloud 直接访问的 Amazon MSK 实例，请选择 无。

有关 数据移动网关 用例的信息，请参阅 什么时候需要 数据移动网关？ 和 常见用例。

云提供商

选择 无 以使用本地 Kafka，或选择 Amazon MSK 以使用 Amazon MSK。

代理服务器

使用以下格式指定一个或多个代理服务器（用于高可用性）：

server1[:port1][,server2[:port2]]

示例：

192.168.1.100:9092,192.168.1.101:9093

数据任务将连接到第一个可用的主机。如果指定主机时未指定端口，则将使用端口 9092 作为默认值。

帐户属性

验证方式

选择以下其中一项：

• 无： 无身份验证。

• 证书：如果您选择此选项，您还需要提供以下信息：

  备注公钥和私钥文件必须采用 PEM 格式。

  • 公钥文件: 浏览到采用 PEM 格式的公钥文件。当您点击保存时，文件将上传到Qlik Talend Cloud并部署到在连接器设置中选择的数据移动网关。
  • 私钥文件：浏览到 PEM 格式的私钥文件。当您点击 保存 时，文件将上传到 Qlik Talend Cloud 并部署到连接器设置中选择的 数据移动网关。
  • 私钥文件密码：私钥文件的密码。

• Kerberos (SASL/GSSAPI)：选择使用 Kerberos 对 Kafka 集群进行身份验证。

  信息注释

  此身份验证方法在所选的 云提供商 为 Amazon MSK 时不可用。

  • 主体：用于对代理服务器进行身份验证的 Kerberos 主体。
  • Keytab 文件：浏览到 keytab 文件。当您点击保存时，文件将上传到Qlik Talend Cloud并部署到在连接器设置中选择的数据移动网关。
  信息注释

  为了在 Linux 上使用 Kerberos 身份验证，应安装 Kerberos 客户端（工作站）软件包。

• 用户名和密码 (SASL/PLAIN)：您可以选择此选项，使用用户名和密码进行身份验证 (SASL/PLAIN)。为防止密码以明文形式发送，强烈建议同时启用启用 TLS选项。

  信息注释

  当选定的云提供商为Amazon MSK时，此身份验证方法不可用。

• 用户名和密码 (SASL/SCRAM-SHA-256)：您可以选择此选项，使用用户名和密码进行身份验证 (SASL/SCRAM-SHA-256)。

  请注意，选择此选项还需要将每个代理的 server.properties 文件配置为相应的 SASL/SCRAM 机制。

  信息注释

  当选定的 云提供商 为 Amazon MSK 时，此身份验证方法不可用。

• 用户名和密码 (SASL/SCRAM-SHA-512)：您可以选择此选项以使用用户名和密码 (SASL/SCRAM-SHA-512) 进行身份验证。

  请注意，选择此选项还需要将每个代理的 server.properties 文件配置为相应的 SASL/SCRAM 机制。

SSL 选项

启用 TLS (支持 TLS 1.0、1.1 和 1.2)

选择此选项以加密 Qlik Talend Cloud 与代理服务器之间的通信。如果代理配置为需要 SSL，则您必须选择此选项。

• CA 文件：浏览到 PEM 格式的 CA 证书。当您单击保存时，文件将上传到 Qlik Talend Cloud 并部署到连接器设置中选择的 数据移动网关。

  信息注释

  当所选的云提供商是Amazon MSK时，不需要。

元数据消息发布

模式注册表将可用于元数据消息发布

从下拉列表中选择以下选项之一：

• 否

  选择此选项后，只有数据消息将被发布。

• Confluent 模式注册表

  如果您选择此选项，您还必须配置Schema registry 连接属性，如下所述。

消息格式

选择 JSON 或 Avro 作为消息格式。如果您选择了 Confluent schema registry，则 Avro 将是唯一可用的选项。

Schema registry 连接属性

Schema registry 服务器

使用以下格式指定一个或多个 Schema Registry 服务器（用于高可用性）：

将数据架构发布到 Confluent Schema Registry 时：

server1:port1[,server2[:port2]]

示例：  

192.168.1.100:8081,192.168.1.101:8081

数据任务将连接到第一个可用的主机。

将数据架构发布到 Hortonworks Schema Registry 时：

server1:port1[,server2[:port2]]

示例：  

192.168.1.100:7788,192.168.1.101:7788

数据任务将连接到第一个可用的主机。

验证方式

选择以下其中一个 Schema Registry 身份验证选项：

• 无：无身份验证。

• Kerberos: 选择使用 Kerberos 进行身份验证。

  信息注释

  要在 Linux 上使用 Kerberos 身份验证，应安装 Kerberos 客户端（工作站）软件包。

• 主体： 用于针对 Schema Registry 进行身份验证的 Kerberos 主体。

• Keytab 文件：浏览到 keytab 文件。当您点击 保存 时，文件将上传到 Qlik Talend Cloud 并部署到连接器设置中选择的任何 数据移动网关。

• 证书：选择使用证书进行身份验证。

  信息注释

  此选项仅在发布到 Confluent Schema Registry 时受支持。

  如果您选择此选项，还需要提供以下信息：

• 公钥文件：浏览到 PEM 格式的公钥文件。当您点击保存时，文件将上传到Qlik Talend Cloud并部署到连接器设置中选择的数据移动网关。
• 私钥文件：浏览到 PEM 格式的私钥文件。当您点击保存时，文件将上传到Qlik Talend Cloud并部署到连接器设置中选择的数据移动网关。
• 私钥密码：私钥文件的密码。

• 用户名和密码：选择使用用户名和密码进行身份验证。然后，在用户名和密码字段中输入您的登录凭据。

  信息注释

  仅在发布到 Confluent Schema Registry 时支持此选项。

• 证书 + 用户名和密码：选择使用证书、用户名和密码进行身份验证。

  选择此选项后，请在上述公钥文件、私钥文件、私钥密码、用户名和密码字段中输入所需信息。

  信息注释

  此选项仅在发布到 Confluent Schema Registry 时受支持。

• 启用 TLS（支持 TLS 1.0、1.1 和 1.2）：选择此选项可加密数据移动网关计算机与 Schema Registry 服务器之间的数据。如果服务器配置为需要 SSL，则您必须选择此选项。

  • CA 文件: 浏览 PEM 格式的 CA 证书。当您点击保存时，文件将上传到Qlik Talend Cloud并部署到在连接器设置中选择的数据移动网关。

内部属性

内部属性用于特殊用例，因此不会在对话框中公开。只有在 Qlik 支持部门的指示下，您才应该使用它们。

使用字段右侧的 和 按钮可以根据需要添加或删除特性。

名称

连接的显示名称。

先决条件