第 10 章 为 Kafka 组件配置日志记录
在配置属性中直接配置 Kafka 组件的日志记录级别。您还可以动态更改 Kafka 代理、Kafka Connect 和 MirrorMaker 2 的代理级别。
增加日志级别详情,如从 INFO 升级到 DEBUG,有助于对 Kafka 集群进行故障排除。但是,更详细的日志也可能对性能造成负面影响,并更难以诊断问题。
10.1. 配置 Kafka 日志记录属性
Kafka 组件使用 Log4j 框架进行错误日志记录。默认情况下,日志记录配置使用以下属性文件从 classpath 或 config
目录中读取:
-
Kafka 的
log4j.properties
-
Kafka Connect 和 MirrorMaker 2 的
connect-log4j.properties
如果没有明确设置,日志记录器会继承每个文件中的 log4j.rootLogger
日志记录级别配置。您可以更改这些文件中的日志级别。您还可以为其他日志记录器添加和设置日志记录级别。
您可以使用 KAFKA_LOG4J_OPTS
环境变量来更改日志记录属性文件的位置和名称,该变量供组件的启动脚本使用。
传递 Kafka 节点使用的日志属性文件的名称和位置
su - kafka export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/my/path/to/log4j.properties"; \ /opt/kafka/bin/kafka-server-start.sh \ /opt/kafka/config/kraft/server.properties
传递 Kafka Connect 使用的日志属性文件的名称和位置
su - kafka export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/my/path/to/connect-log4j.properties"; \ /opt/kafka/bin/connect-distributed.sh \ /opt/kafka/config/connect-distributed.properties
传递 MirrorMaker 2 使用的日志属性文件的名称和位置
su - kafka export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/my/path/to/connect-log4j.properties"; \ /opt/kafka/bin/connect-mirror-maker.sh \ /opt/kafka/config/connect-mirror-maker.properties