备注

此连接器受 Snowflake 连接器条款 的约束。

Snowflake Openflow Connector for Kafka：配置 AWS MSK IAM 身份验证

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

先决条件

  • Kafka 集群必须是启用了 IAM 身份验证的 Amazon MSK。

  • 您需要在 Openflow 中提供 IAM 凭据，并在云中部署 BYOC（自带云）配置。

  • IAM 角色或用户必须具有所需的 MSK 权限。

第 1 步：创建 AmazonMSKConnectionService

从 Openflow 画布中，访问 Controller Services 配置：

  1. 双击连接器的处理组

  2. 右键单击画布并选择 Controller Services。

添加一个新的 AmazonMSKConnectionService：

  1. 选择 + 以添加新的控制器服务。

  2. 从列表中选择 AmazonMSKConnectionService。

  3. 选择 Add。

配置 AmazonMSKConnectionService 属性：

属性

值

SASL 机制

AWS_MSK_IAM

安全协议

#{Kafka Security Protocol}

引导服务器

#{Kafka Bootstrap Servers}

验证 AmazonMSKConnectionService：

  1. 为服务选择 Verify。

  2. 确认服务状态显示为 Verified。

第 2 步：配置 ConsumeKafka 处理器

  1. 在 Kafka Connector 中，找到 ConsumeKafka 处理器

  2. 将处理器配置为使用新的连接服务：

    将 Kafka Connection Service 属性设置为您在 第 1 步：创建 AmazonMSKConnectionService 中创建的 AmazonMSKConnectionService。

第 3 步（可选）：删除旧的 Kafka 连接服务

  1. 在 Controller Services 选项卡中，找到旧的 Kafka3Connection 服务。

  2. 禁用并删除旧服务：

    1. 对旧服务选择 Disable。

    2. 禁用后，选择 Delete 以移除旧服务。