为什么 Apache Kafka 消费者不使用 Log4j2 根记录器？

Question

我有这个配置：

pom.xml

<dependency>
  <groupId>org.apache.logging.log4j</groupId>
  <artifactId>log4j-api</artifactId>
  <version>2.11.1</version>
</dependency>
<dependency>
  <groupId>org.apache.logging.log4j</groupId>
  <artifactId>log4j-core</artifactId>
  <version>2.11.1</version>
</dependency>

<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
  <version>1.0.1</version>
</dependency>

resources/log4j2.属性

name=PropertiesConfig
appenders = console
appender.console.type = Console
appender.console.name = STDOUT
appender.console.layout.type = PatternLayout
appender.console.layout.pattern = [%-5level] %d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %c{1} - %msg%n
rootLogger.level = ERROR
rootLogger.appenderRefs = stdout
rootLogger.appenderRef.stdout.ref = STDOUT

当我使用 org.apache.kafka.clients.consumer.KafkaConsumer 启动我的 Kafka 消费者时，它在 INFO 级别进行日志记录。我使用 LogManager.getLogger(name) 创建的任何新记录器都支持级别 ERROR 的配置和日志，因此我知道正在加载和使用 log4j2.properties 文件。卡夫卡似乎忽略了它。在日志中，当 Kafka 消费者启动时，我多次看到这一行：

Aug 20, 2018 11:03:37 PM org.apache.kafka.common.utils.LogContext$KafkaLogger info

感谢任何帮助！

Answer 1

Kafka 通过 SLF4J 登录。如果你想使用Log4j2，你必须配置两者一起工作（通过添加Log4j2提供的SLF4J实现）：

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-slf4j-impl</artifactId>
    <version>2.11.1</version>
</dependency>

如果没有这个，SLF4J 的日志输出将使用其他一些后端（确保删除那个后端，类路径上不应有任何其他 slf4j-impl）并忽略您的 Log4j2 配置。

为什么 Apache Kafka 消费者不使用 Log4j2 根记录器？

Why doesn't the Apache Kafka consumer use the Log4j2 root logger?

java

slf4j

apache-kafka

log4j2

kafka-consumer-api

pom.xml

resources/log4j2.属性