Log4j2 2.7版本Failover Appender失效问题咨询

让我们一步步拆解你的问题，先解决Kafka Appender的报错，再处理Failover Appender的版本bug：

一、先排查Kafka Appender的基础问题 #

从你给出的配置和kafka-producer-network-thread相关报错来看，大概率是Kafka连接、依赖或配置细节出了问题：

1. 确保依赖完整且版本一致 #

Spring Boot默认用Logback，你需要先排除它，再引入Log4j2和Kafka Appender的依赖，所有Log4j2组件版本必须统一（都是2.7），比如Maven配置：

<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>
    </exclusions>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-log4j2</artifactId>
    <version>你的Spring Boot版本对应版本</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.7</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-kafka-appender</artifactId>
    <version>2.7</version>
</dependency>
<!-- Async Appender依赖Disruptor -->
<dependency>
    <groupId>com.lmax</groupId>
    <artifactId>disruptor</artifactId>
    <version>3.3.4</version>
</dependency>

2. 验证Kafka服务和Topic可用性 #

• 先确认本地Kafka服务是否正常启动：执行telnet 127.0.0.1 9092或nc -zv 127.0.0.1 9092，能连通才说明服务正常。
• 检查logs Topic是否存在：Kafka默认不会自动创建Topic，手动创建命令：

kafka-topics.sh --create --topic logs --bootstrap-server 127.0.0.1:9092 --partitions 1 --replication-factor 1

3. 优化Kafka Producer配置 #

你的配置只加了bootstrap.servers，缺少必要的容错配置，容易因网络波动或Kafka临时不可用报错，建议补充：

<Kafka name="kafkaAppender" topic="logs" ignoreExceptions="false" >
  <PatternLayout pattern="%m%n" />
  <Property name="bootstrap.servers">127.0.0.1:9092</Property>
  <!-- 增加容错配置 -->
  <Property name="acks">1</Property> <!-- 至少等待leader确认 -->
  <Property name="retries">3</Property> <!-- 失败重试次数 -->
  <Property name="delivery.timeout.ms">30000</Property> <!-- 投递超时时间 -->
  <Property name="linger.ms">10</Property> <!-- 批量发送优化 -->
</Kafka>

4. 调整Async Appender的异常处理 #

你设置了ignoreExceptions="false"，这会导致Kafka Appender报错时直接抛出异常，可能阻塞应用日志流程。建议改为true，并添加备用Appender（比如文件输出），避免日志丢失：

<Async name="Async" ignoreExceptions="true" >
  <AppenderRef ref="kafkaAppender"/>
  <AppenderRef ref="fileAppender"/> <!-- 备用文件日志，防止Kafka不可用丢日志 -->
</Async>

<!-- 新增备用的File Appender示例 -->
<RollingFile name="fileAppender" fileName="logs/app.log" filePattern="logs/app-%d{yyyy-MM-dd}.log">
  <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss} [%t] %-5level %logger{36} - %msg%n"/>
  <SizeBasedTriggeringPolicy size="10MB"/>
</RollingFile>

二、解决Log4j2 2.7版本Failover Appender失效问题 #

这是Log4j2 2.7版本的已知bug，主要问题包括：主Appender恢复后无法自动切回、故障切换逻辑异常等。这个问题在2.8及以上版本已经修复，所以有两个解决方案：

1. 优先升级Log4j2版本 #

建议升级到稳定版（比如2.17.1，注意避开有漏洞的旧版本），同时确保所有Log4j2组件版本统一。升级后Failover Appender就能正常工作，配置示例：

<Failover name="failoverAppender" primary="kafkaAppender">
  <Failovers>
    <AppenderRef ref="fileAppender"/> <!-- 备用Appender -->
  </Failovers>
</Failover>

2. 临时替代方案（无法升级时） #

如果暂时不能升级版本，可以用Routing Appender模拟故障转移逻辑，通过判断Kafka连接状态动态切换Appender，或者直接用前面提到的Async Appender同时配置主备Appender的方式兜底。

最后提示 #

如果kafka-producer-network-thread的报错还有具体信息（比如连接超时、序列化错误），可以针对性排查：

• 连接超时：检查Kafka的listeners配置是否正确，确保对外暴露的是127.0.0.1:9092
• 序列化错误：默认Kafka Appender用StringSerializer，确保日志消息是字符串类型（你的%m%n格式没问题）

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