10.3. Kafka Connect 및 MirrorMaker 2의 로깅 수준을 동적으로 변경

프로세스

1. kafka 사용자로 전환합니다.

   su - kafka

2. connect-log4j.properties 파일에 구성된 로거의 현재 로깅 수준을 확인합니다.

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

   curl 명령을 사용하여 Kafka Connect API의 admin/loggers 끝점에서 로깅 수준을 확인합니다.

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

   jq 는 JSON 형식으로 출력을 출력합니다. 이 목록에는 표준 조직 및 루트 수준 로거와 수정된 로깅 수준이 있는 특정 로거가 표시되어 있습니다.

   Kafka Connect에서 admin.listeners 구성에 대해 TLS(Transport Layer Security) 인증을 구성하는 경우 로거 끝점의 주소는 https와 같은 https 프로토콜을 사용하여 admin.listeners 에 지정된 값입니다.

   특정 로거의 로그 수준을 가져올 수도 있습니다.

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

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"
     }
   }

   루트 로거를 변경하면 기본적으로 루트 로깅 수준을 사용하는 로거의 로깅 수준도 변경됩니다.