更新连接器

使用 Amazon Web Services 管理控制台 更新连接器配置

1. 在 https://console.amazonaws.cn/msk/ 打开 Amazon MSK 控制台。

2. 在左侧窗格的 MSK Connect 下，选择连接器。

3. 选择现有的连接器。

4. 选择编辑连接器配置。

5. 更新连接器配置。无法使用 UpdateConnector 覆盖 connector.class。以下是 Confluent Amazon S3 Sink Connector 的配置示例。

   connector.class=io.confluent.connect.s3.S3SinkConnector
   tasks.max=2
   topics=my-example-topic
   s3.region=us-east-1
   s3.bucket.name=amzn-s3-demo-bucket
   flush.size=1
   storage.class=io.confluent.connect.s3.storage.S3Storage
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   schema.compatibility=NONE

6. 选择提交。

7. 然后，可以在连接器的操作选项卡中监视操作的当前状态。