logging - 如何为 Kafka 生产者配置日志记录?

标签 logging log4j apache-kafka kafka-producer-api

我正在使用 Kafka 生产者客户端,并且我的项目中没有任何 log4j 配置。

运行时,程序会打印大量我真的不想要的 Kafka 调试日志。

因此,我尝试添加 log4j.properties 将日志级别设置为 ERROR,如下所示,这似乎不起作用:

log4j.rootLogger=ERROR

如何更改 Kafka 日志级别?

最佳答案

运行客户端时使用命令行标志-Dlog4j.configuration=file:/path/to/log4j.properties

示例 log4j 属性文件:

对于镜像制作器和其他导致调用kafka-run-class.sh的工具,您可以使用环境变量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

关于logging - 如何为 Kafka 生产者配置日志记录?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35773780/

相关文章:

java - 未找到 WildFly 9.0.1 WFLYCTL0158 处理程序 "CONSOLE"

java - log4j:输出文件取决于源调用类

java - 如何在运行时设置log4j的DB Credentials

java - Kafka 消费者在 SSL 上抛出 "OutOfMemoryError: Java heap space"错误

java - spring-kafka:如何将一个方法传递给另一个方法,该方法(根据设计)永远不会返回?

linux - 如何使用 Nagios 监控生成随机 ID 的日志文件

javascript - 不调试时如何禁用 console.log?

java - google eclipse插件创建的log4j.properties和logging.properties有什么区别?

java - Log4j 登录到多个文件

apache-kafka - 如何在不分区主题的情况下实现多处理,消费kafka消息?