为 Openflow Connector for Kafka 配置其他身份验证方法¶

备注

使用该连接器需遵守连接器条款。

本主题介绍如何为 Openflow Connector for Kafka 配置其他身份验证方法。除基本 SASL 身份验证外，连接器还支持多种身份验证机制。

备注

基本 SASL 身份验证是通过参数上下文配置的，如设置 Openflow Connector for Kafka 中所述。本页介绍了其他需要额外服务配置的身份验证方法。

支持的身份验证方法¶

Openflow Connector for Kafka 支持以下身份验证机制：

mTLS（双向传输层安全）身份验证需要客户端和服务器都提供用于双向身份验证的证书。

在配置 mTLS 身份验证之前，请确保您已执行以下操作：

从 NiFi 画布访问 Controller Services 配置：
- 双击连接器的处理组
- 右键点击画布并选择 Controller Services
添加新的 StandardSSLContextService。
- 点击 + 以添加新的控制器服务。
- 从列表中选择 StandardSSLContextService。
- 点击 Add。

配置 SSL Context Service 属性：

属性	值
Keystore Filename	密钥库文件完整路径（例如，`/path/to/client-keystore.p12`）或资产引用
Keystore Password	密钥库的密码
Keystore Type	密钥库格式（`PKCS12`、`JKS` 或 `BCFKS`）
Key Password	私钥的密码（如果密钥已加密）
信任库文件名	信任库文件完整路径（例如，`/path/to/client-truststore.p12`）或资产引用
信任库密码	信任库的密码
信任库类型	信任库格式（`PKCS12`、`JKS` 或 `BCFKS`）

属性	值
安全协议	`SSL`
SSL Context Service	选择您在第 1 步中创建的 SSL Context Service

AWS MSK IAM 身份验证允许您使用 AWS 身份和访问管理 (IAM) 对 Amazon Managed Streaming for Apache Kafka (MSK) 进行身份验证。

从 NiFi 画布访问 Controller Services 配置：
- 双击连接器的处理组
- 右键点击画布并选择 Controller Services
添加新的 AmazonMSKConnectionService。
- 点击 + 以添加新的控制器服务。
- 从列表中选择 AmazonMSKConnectionService。
- 点击 Add
配置 AmazonMSKConnectionService 属性：

属性

值

SASL 机制

AWS_MSK_IAM

安全协议

#{Kafka Security Protocol}

引导服务器

#{Kafka Bootstrap Servers}
验证 AmazonMSKConnectionService：
- 为服务点击 Verify
- 确认服务状态显示为 Verified

在 Kafka 连接器流中，找到 ConsumeKafka 处理器
将处理器配置为使用新的连接服务：
- 将 Kafka Connection Service 属性设置为您在第 1 步：创建 AmazonMSKConnectionService 中创建的 AmazonMSKConnectionService。