更新连接器 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

更新连接器

此过程介绍如何使用更新现有 MSK Connect 连接器的配置。 Amazon Web Services Management Console

使用更新连接器配置 Amazon Web Services Management Console
  1. https://console.amazonaws.cn/msk/ 打开 Amazon MSK 控制台。

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

  3. 选择现有的连接器。

  4. 选择编辑连接器配置

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

    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. 然后,您可以在连接器的 “操作” 选项卡中监视操作的当前状态。

要使用 MSK Connect API 更新连接器的配置,请参阅UpdateConnector