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.reflections=ERROR

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

   jq 以 JSON 格式打印输出。列表显示标准的 org 和 root 级别的日志程序，以及特定的带有改变的日志级别的日志程序。

   如果您在 Kafka Connect 中为 admin.listeners 配置配置 TLS (Transport Layer Security)身份验证，则 loggers 端点的地址是为 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 日志级别的日志程序的日志级别也会被改变。