我使用的是kafka producer客户端,在我的项目中没有任何log4j配置。在运行时,程序打印了很多我不想要的kafka调试日志。因此,我尝试添加log4j.properties将日志级别设置为error,如下所示,但似乎不起作用:
log4j.rootLogger=ERROR
如何更改kafka日志级别?
hs1rzwqc1#
使用命令行标志 -Dlog4j.configuration=file:/path/to/log4j.properties 运行客户端时。log4j属性文件示例:https://github.com/apache/kafka/blob/trunk/config/tools-log4j.properties被mirror maker之类的工具使用,真的只是标准输出https://github.com/apache/kafka/blob/trunk/config/log4j.propertiesKafka服务器等工具使用对于mirror maker和其他导致调用 kafka-run-class.sh ,可以使用env变量 KAFKA_LOG4J_OPTS (设置为 -Dlog4j.configuration=file:/path/to/log4j.properties )更改日志记录配置。请参见:https://github.com/apache/kafka/blob/0.10.2/bin/kafka-run-class.sh#l158我的例子 log4j.properties 我用于测试的镜像生成器的文件。
-Dlog4j.configuration=file:/path/to/log4j.properties
kafka-run-class.sh
KAFKA_LOG4J_OPTS
log4j.properties
# https://github.com/apache/kafka/blob/trunk/config/tools-log4j.properties log4j.rootLogger=DEBUG, stderr log4j.appender.stderr=org.apache.log4j.ConsoleAppender log4j.appender.stderr.layout=org.apache.log4j.PatternLayout log4j.appender.stderr.layout.ConversionPattern=[%d] %p %m (%c)%n log4j.appender.stderr.Target=System.err
4dbbbstv2#
org.apache.log4j.Logger.getLogger("org").setLevel(Level.WARN); org.apache.log4j.Logger.getLogger("akka").setLevel(Level.WARN); org.apache.log4j.Logger.getLogger("kafka").setLevel(Level.WARN);
elcex8rz3#
我以为你说的是Kafka服务器日志。您可以使用以下配置将日志级别更改为error
log4j.logger.kafka=ERROR, kafkaAppender
希望这有帮助!
hjzp0vay4#
尝试将logging.level.org.apache.kafka:debug添加到客户端配置属性中。我用的是springboot,格式是这样的。为你的客户程序使用适当的格式。
qvtsj1bj5#
在中定义日志记录级别,如下所示 application.yml 文件或您的属性文件。
application.yml
logging: level: root: INFO org: apache: kafka: WARN
通过定义上述内容,kafka将只打印警告日志。
5条答案
按热度按时间hs1rzwqc1#
使用命令行标志
-Dlog4j.configuration=file:/path/to/log4j.properties
运行客户端时。log4j属性文件示例:
https://github.com/apache/kafka/blob/trunk/config/tools-log4j.properties
被mirror maker之类的工具使用,真的只是标准输出
https://github.com/apache/kafka/blob/trunk/config/log4j.properties
Kafka服务器等工具使用
对于mirror maker和其他导致调用
kafka-run-class.sh
,可以使用env变量KAFKA_LOG4J_OPTS
(设置为-Dlog4j.configuration=file:/path/to/log4j.properties
)更改日志记录配置。请参见:https://github.com/apache/kafka/blob/0.10.2/bin/kafka-run-class.sh#l158我的例子
log4j.properties
我用于测试的镜像生成器的文件。4dbbbstv2#
elcex8rz3#
我以为你说的是Kafka服务器日志。您可以使用以下配置将日志级别更改为error
希望这有帮助!
hjzp0vay4#
尝试将logging.level.org.apache.kafka:debug添加到客户端配置属性中。我用的是springboot,格式是这样的。为你的客户程序使用适当的格式。
qvtsj1bj5#
在中定义日志记录级别,如下所示
application.yml
文件或您的属性文件。通过定义上述内容,kafka将只打印警告日志。