Kafka Java客户端日志配置不生效，整合Camel/SpringBoot后如何强制统一？

POM依赖配置 #

<!--logging-->
<!--强制JCL和log4j使用SLF4J，同时强制SLF4J以JUL作为具体实现-->
<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-streams</artifactId><version>3.6.1</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId>
    <version>2.0.17</version>
</dependency>

<dependency>
    <groupId>org.slf4j</groupId><artifactId>jcl-over-slf4j</artifactId>
    <version>2.0.17</version>
</dependency>

<dependency>
    <groupId>org.slf4j</groupId><artifactId>log4j-over-slf4j</artifactId>
    <version>2.0.17</version>
</dependency>

<dependency>
    <groupId>org.slf4j</groupId><artifactId>slf4j-jdk14</artifactId>
    <version>2.0.17</version>
</dependency>

JUL日志配置文件（/app.logging.properties） #

handlers = java.util.logging.FileHandler

# 单个日志文件最大5MB，最多保留5个文件
java.util.logging.FileHandler.pattern = /var/output.log
java.util.logging.FileHandler.limit = 5000000
java.util.logging.FileHandler.level = ALL
java.util.logging.FileHandler.count = 5
java.util.logging.FileHandler.formatter = java.util.logging.SimpleFormatter

# 默认日志级别为INFO
.level = INFO

启动命令 #

java -Djava.util.logging.config.file=/app.logging.properties -jar app.jar

问题现象 #

Kafka相关日志并未输出到指定的/var/output.log，而是直接打印到标准错误流，示例如下：

[2025-05-06 10:45:23.012] - 546981 INFO [kafka-producer-network-thread | producer-6] --- org.apache.kafka.clients.Metadata: [Producer clientId=producer-6] Cluster ID: QDoxYTzkQ86b9RUDpEaS8B
[2025-05-06 10:54:21.233] - 546981 INFO [kafka-producer-network-thread | producer-1] --- org.apache.kafka.clients.NetworkClient: [Producer clientId=producer-1] Node -1 disconnected.

更新说明 #

该问题仅在POM中加入Camel/SpringBoot Starter后出现，如何强制这些组件使用指定的日志配置？

问题根源 #

加入SpringBoot/Camel Starter后，Spring Boot默认引入的spring-boot-starter-logging会绑定logback-classic作为SLF4J的默认实现，直接覆盖了你配置的slf4j-jdk14。同时Spring Boot会在启动初期就初始化Logback，导致Kafka的日志通过Logback输出到控制台（标准错误流），而非你定义的JUL配置。

解决步骤 #

1. 排除Spring Boot默认的日志依赖
   在Spring Boot/Camel Starter依赖中排除spring-boot-starter-logging和logback-classic，避免其干扰自定义日志配置：

   <!-- Spring Boot Starter排除默认日志 -->
   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter</artifactId>
       <exclusions>
           <exclusion>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-logging</artifactId>
           </exclusion>
           <exclusion>
               <groupId>ch.qos.logback</groupId>
               <artifactId>logback-classic</artifactId>
           </exclusion>
       </exclusions>
   </dependency>
   
   <!-- Camel SpringBoot Starter同样排除默认日志 -->
   <dependency>
       <groupId>org.apache.camel.springboot</groupId>
       <artifactId>camel-spring-boot-starter</artifactId>
       <exclusions>
           <exclusion>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-logging</artifactId>
           </exclusion>
           <exclusion>
               <groupId>ch.qos.logback</groupId>
               <artifactId>logback-classic</artifactId>
           </exclusion>
       </exclusions>
   </dependency>
   

2. 确保JUL配置被优先加载
   Spring Boot启动时可能提前初始化日志系统，导致java.util.logging.config.file参数未生效，可通过两种方式解决：

   • 在启动类main方法最开头手动加载JUL配置：

     public static void main(String[] args) throws IOException {
         LogManager.getLogManager().readConfiguration(new FileInputStream("/app.logging.properties"));
         SpringApplication.run(YourApplication.class, args);
     }
     

   • 或者添加系统属性禁止Spring Boot自动配置日志系统，让JUL完全接管：

     java -Djava.util.logging.config.file=/app.logging.properties -Dorg.springframework.boot.logging.LoggingSystem=none -jar app.jar
     

3. 验证依赖树
   执行mvn dependency:tree命令，确认项目中没有引入logback-classic、log4j-core等其他日志实现，确保仅保留slf4j-api、jcl-over-slf4j、log4j-over-slf4j、slf4j-jdk14这些依赖。

4. 单独配置Kafka的JUL日志级别
   在JUL配置文件中明确指定Kafka相关包的日志级别，确保日志被正确捕获：

   org.apache.kafka.level = INFO
   

内容的提问来源于stack exchange，提问作者simonalexander2005