目录

Search

  1. 前言
  2. 工作流管理器
  3. 工作流和工作集
  4. 会话
  5. 会话配置对象
  6. 任务
  7. 目标
  8. 连接对象
  9. 验证
  10. 计划和运行工作流
  11. 发送电子邮件
  12. Workflow Monitor
  13. Workflow Monitor 详细信息
  14. 会话和工作流日志
  15. 会话属性参考
  16. 工作流属性参考

工作流基本指南

工作流基本指南

PowerExchange for Kafka 连接

PowerExchange for Kafka 连接

在配置 Kafka 连接时,需要定义 PowerCenter 集成服务连接到 Kafka 群集时要使用的连接属性。可以配置 SSL 属性来通过 SSL 连接到 Kafka Broker。
下表介绍了 Kafka 连接属性:
属性
说明
Kafka Broker 列表
Kafka 消息传递系统 Broker 列表的 IP 地址和端口组合。
IP 地址和端口组合的格式如下:
<IP 地址>:<端口>
可以输入多个以逗号分隔的 IP 地址和端口组合。
重试超时(秒)
集成服务尝试重新连接到 Kafka Broker 以写入数据的秒数。
如果在指定的时间无法连接源或目标,将停止执行映射,以免丢失数据。
默认值为 180 秒。
Kafka Broker 版本
选择
Apache 0.10.1.1 及更高版本
作为 Kafka Broker 消息版本。
其他连接属性
连接到 Kafka Broker 的以逗号分隔的连接属性列表。
要通过 SSL 连接到 Kafka Broker,请确保设置以下属性:
  • security.protocol
  • ssl.truststore.location
  • ssl.truststore.password
如果将
ssl.client.auth
参数设置为
required
requested
,请确保设置以下属性:
  • ssl.keystore.location
  • ssl.keystore.password
  • ssl.key.password
例如,
security.protocol=SSL,ssl.truststore.location=<client.truststore.jks 文件的完整路径和名称>,ssl.truststore.password=<客户端信任库密码>,ssl.keystore.location=<client.keystore.jks 文件的完整路径和名称>,ssl.keystore.password=<客户端密钥库密码>,ssl.key.password=<单个密钥的密码>
您也可以指定连接到 Kerberised Kafka 群集所需的配置属性。
指定以下属性:
security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI
SSL 模式
指定 PowerCenter 集成服务是否与 Kafka Broker 建立安全连接。可以选择以下选项之一:
  • 已禁用。PowerCenter 集成服务与 Kafka Broker 建立不加密连接。
  • 需要。PowerCenter 集成服务与 Kafka Broker 建立加密连接,但不验证服务器的标识。
  • 单向。PowerCenter 集成服务使用信任库文件和信任库密码与 Kafka Broker 建立加密连接。
  • 双向。PowerCenter 集成服务使用信任库文件和信任库密码与 Kafka Broker 建立加密连接。
SSL TrustStore 文件路径
仅适用于将
单向
双向
选作 SSL 模式的情况。
信任库文件的完整路径和文件名。信任库文件包含 Kafka Broker 群集根据 Kafka Broker 证书验证的 SSL 证书。
SSL TrustStore 密码
仅适用于将
单向
双向
选作 SSL 模式的情况。
信任库文件的密码。
SSL 密钥库文件路径
仅适用于将
双向
选作 SSL 模式的情况。
Java 密钥库文件的完整路径和文件名。密钥库文件包含 Kafka Broker 根据 Kafka Broker 群集证书验证的证书。
SSL 密钥库密码
仅适用于将
双向
选作 SSL 模式的情况。
密钥库文件的密码。
其他安全属性
不适用于 PowerExchange for Kafka。