创建连接器

创建连接器

1. 登录并打开亚马逊 MSK 控制台 Amazon Web Services 管理控制台，网址为？https://console.aws.amazon.com/msk/homeregion=us -east-1#/home/。

2. 在左侧窗格中，展开 MSK Connect，然后选择连接器。

3. 选择 Create connector (创建连接器)。

4. 在插件列表中，选择 mkc-tutorial-plugin，然后选择下一步。

5. 对于连接器名称，请输入 mkc-tutorial-connector。

6. 在集群列表中，选择 mkc-tutorial-cluster。

7. 在连接器网络设置部分中，为网络类型选择以下选项之一：

   • IPv4（默认）-仅用于通过 IPv4 连接到目的地

   • Dual-stack-用于通过 IPv4 和 IPv6 连接到目的地（仅当您的子网有 IPv4 和 IPv6 CIDR 块关联时才可用）

8. 复制以下配置，并将其粘贴到连接器配置字段中。

   确保将区域替换为 Amazon Web Services 区域 创建连接器的代码。此外，在以下示例中，将 Amazon S3 存储桶名称替换为您的存储桶名称。<amzn-s3-demo-bucket-my-tutorial>

   connector.class=io.confluent.connect.s3.S3SinkConnector
   s3.region=us-east-1
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   flush.size=1
   schema.compatibility=NONE
   tasks.max=2
   topics=mkc-tutorial-topic
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   storage.class=io.confluent.connect.s3.storage.S3Storage
   s3.bucket.name=<amzn-s3-demo-bucket-my-tutorial>
   topics.dir=tutorial

9. 在访问权限下，选择 mkc-tutorial-role。

10. 选择下一步。在安全性页面上，再次选择下一步。

11. 在日志页面上，选择下一步。

12. 在查看并创建页面上，查看您的连接器配置，然后选择创建连接器。