10.3. 为 Kafka Connect 和 MirrorMaker 2 动态更改日志记录级别

流程

1. 切换到 kafka 用户：

   su - kafka

   Copy to Clipboard Toggle word wrap

2. 检查 connect-log4j.properties 文件中配置的日志记录器的当前日志记录级别：

   $ cat /opt/kafka/config/connect-log4j.properties
   
   # ...
   log4j.rootLogger=INFO, stdout, connectAppender
   # ...
   log4j.logger.org.apache.zookeeper=ERROR
   log4j.logger.org.reflections=ERROR

   Copy to Clipboard Toggle word wrap

   使用 curl 命令从 Kafka Connect API 的 admin/loggers 端点检查日志级别：

   curl -s http://localhost:8083/admin/loggers/ | jq
   
   {
     "org.apache.zookeeper": {
       "level": "ERROR"
     },
     "org.reflections": {
       "level": "ERROR"
     },
     "root": {
       "level": "INFO"
     }
   }

   Copy to Clipboard Toggle word wrap

   jq 以 JSON 格式输出。该列表显示了标准 机构 和 根级别 日志记录器，以及具有修改日志级别的任何特定日志记录器。

   如果您在 Kafka Connect 中为 admin.listeners 配置配置 TLS (Transport Layer Security)身份验证，则日志记录器端点的地址是 admin.listeners 指定的值，其协议为 https，如 https://localhost:8083。

   您还可以获取特定日志记录器的日志级别：

   curl -s http://localhost:8083/admin/loggers/org.apache.kafka.connect.mirror.MirrorCheckpointConnector | jq
   
   {
     "level": "INFO"
   }

   Copy to Clipboard Toggle word wrap

3. 使用 PUT 方法更改日志记录器的日志级别：

   curl -Ss -X PUT -H 'Content-Type: application/json' -d '{"level": "TRACE"}' http://localhost:8083/admin/loggers/root
   
   {
     # ...
   
     "org.reflections": {
       "level": "TRACE"
     },
     "org.reflections.Reflections": {
       "level": "TRACE"
     },
     "root": {
       "level": "TRACE"
     }
   }

   Copy to Clipboard Toggle word wrap

   如果您更改了 root 日志程序，则默认使用了 root 日志级别的日志程序的日志级别也会被改变。