成功创建FC Sink Connector后,您可以在消息队列Kafka版控制台更新其配置。

操作步骤

  1. 登录消息队列Kafka版控制台
  2. 概览页面的资源分布区域,选择地域。
  3. 实例列表页面,单击目标实例名称。
  4. 在左侧导航栏,单击Connector 管理
  5. Connector 管理页面,找到目标Connector,在其操作列,选择更多 > 修改配置
  6. 修改配置面板,按需修改以下参数,然后单击确定
    参数 描述
    消费线程并发数 数据源Topic的消费线程并发数。默认值为6。取值说明如下:
    • 1
    • 2
    • 3
    • 6
    • 12
    失败处理 消息发送失败后,是否继续订阅出现错误的Topic的分区。取值说明如下。
    • 继续订阅:继续订阅出现错误的Topic的分区,并打印错误日志。
    • 停止订阅:停止订阅出现错误的Topic的分区,并打印错误日志。
    说明
    • 如何查看日志,请参见查看Connector日志
    • 如何根据错误码查找解决方案,请参见错误码
    • 如需恢复对出现错误的Topic的分区的订阅,您需要提交工单联系消息队列Kafka版技术人员。
    重试次数 消息发送失败后的重试次数。默认为2。取值范围为1~3。部分导致消息发送失败的错误不支持重试。错误码与是否支持重试的对应关系如下:
    • 4XX:除429支持重试外,其余错误码不支持重试。
    • 5XX:支持重试。
    说明 Connector调用InvokeFunction向函数计算发送消息。

执行结果

修改完成后,在Connector 管理页面,找到目标Connector,单击其操作列的详情。在Connector的详情页面,查看到更新后的Connector配置。