如何通过AWS MSK Connect API/CLI修改Kafka Snowflake连接器日志级别？

是的，你可以通过AWS MSK Connect的API或CLI调整连接器的日志级别，具体操作步骤如下：

使用AWS CLI修改 #

1. 先获取目标连接器的当前配置，确认现有日志相关设置：

   aws kafka-connect describe-connector --connector-name <你的连接器名称>
   

2. 在返回结果中找到logDelivery字段（无该字段则直接添加），修改全局Worker日志级别或指定Snowflake连接器的插件日志级别。例如将全局Worker日志设为DEBUG，Snowflake连接器日志设为TRACE：

   aws kafka-connect update-connector --connector-name <你的连接器名称> --connector-config '{
     "logDelivery": {
       "workerLogLevel": "DEBUG",
       "pluginLogLevels": {
         "com.snowflake.kafka.connector": "TRACE"
       }
     },
     // 保留原连接器的所有其他必要配置项
   }'
   

   注意：必须保留原有连接器的全部核心配置参数，仅修改日志相关部分，避免覆盖配置导致连接器异常。

使用AWS MSK Connect API修改 #

调用UpdateConnector接口，在请求体中传入更新后的配置，重点调整logDelivery节点：

PUT /v1/connectors/<connector-name> HTTP/1.1
Host: kafka-connect.<region>.amazonaws.com
Content-Type: application/json

{
  "connectorConfig": {
    "logDelivery": {
      "workerLogLevel": "DEBUG",
      "pluginLogLevels": {
        "com.snowflake.kafka.connector": "TRACE"
      }
    },
    // 保留原连接器的其他配置参数
  }
}

注意事项 #

• 支持的日志级别包括：TRACE、DEBUG、INFO、WARN、ERROR
• 修改配置后，MSK Connect会自动重启连接器以应用新的日志设置
• 若连接器原配置无logDelivery字段，直接添加该节点即可生效
• 指定Snowflake连接器日志级别时，需使用其包路径com.snowflake.kafka.connector，确保日志精准指向该插件

内容的提问来源于stack exchange，提问作者erase.ego