如何为kafka生产者配置日志记录?

6ss1mwsb  于 2021-06-07  发布在  Kafka
关注(0)|答案(5)|浏览(530)

我使用的是kafka producer客户端,在我的项目中没有任何log4j配置。
在运行时,程序打印了很多我不想要的kafka调试日志。
因此,我尝试添加log4j.properties将日志级别设置为error,如下所示,但似乎不起作用:

log4j.rootLogger=ERROR

如何更改kafka日志级别?

hs1rzwqc

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 我用于测试的镜像生成器的文件。


# 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
4dbbbstv

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);
elcex8rz

elcex8rz3#

我以为你说的是Kafka服务器日志。您可以使用以下配置将日志级别更改为error

log4j.logger.kafka=ERROR, kafkaAppender

希望这有帮助!

hjzp0vay

hjzp0vay4#

尝试将logging.level.org.apache.kafka:debug添加到客户端配置属性中。我用的是springboot,格式是这样的。为你的客户程序使用适当的格式。

qvtsj1bj

qvtsj1bj5#

在中定义日志记录级别,如下所示 application.yml 文件或您的属性文件。

logging:
  level:
    root: INFO
    org:
      apache:
        kafka: WARN

通过定义上述内容,kafka将只打印警告日志。

相关问题