SpringBoot中logback日志丢失原因排查与解决方法

@Service
@Slf4j
public class BizMsgServiceImpl {

    @KafkaListener(topics = "${kafka.consumer.deviceEventTopic}", ...)
    public void kafkaDeviceEventListen(ConsumerRecord<String, String> record) {
        // ... 解析事件 ...
        String msgServiceBusinessId = event.getDeviceId() + "_" + event.getDeviceSn() + "_" + event.getOccurTime();
        // 保存到本地设备事件表
        saveDeviceEventMessage(event, containerId, msgServiceBusinessId);
        // ... 后续推送消息中心 ...
        LogUtils.BIZ.info("发送设备事件消息=> {}", Collections.singletonList(msgInfoReqDTO));
        msgInfoService.savaMsgInfoPOS(Collections.singletonList(msgInfoReqDTO));
    }

    /**
     * 将Kafka设备事件保存到本地设备事件表
     * business_id 存在唯一索引，重复事件插入失败时仅告警不阻断
     */
    private void saveDeviceEventMessage(DeviceEventEntity event, String containerId, String businessId) {
        try {
            DeviceEventMessagePO po = new DeviceEventMessagePO();
            // ... set 各字段 ...
            deviceEventMessageMapper.insert(po);
        } catch (Exception e) {
            log.warn("保存设备事件到本地表失败 businessId={}", businessId, e);
        }
    }
}

<root level="INFO">
    <appender-ref ref="STDOUT"/>
    <appender-ref ref="ASYNC_INFO"/>
    <appender-ref ref="ASYNC_ERROR"/>
</root>

<!-- root logger：只挂了 STDOUT、ASYNC_INFO、ASYNC_ERROR，没有 ASYNC_WARN！ -->
<root level="INFO">
    <appender-ref ref="STDOUT"/>
    <appender-ref ref="ASYNC_INFO"/>
    <appender-ref ref="ASYNC_ERROR"/>
</root>
<!-- BIZ logger：挂了 ASYNC_WARN -->
<logger name="BIZ" level="DEBUG" additivity="false">
    <appender-ref ref="STDOUT"/>
    <appender-ref ref="ASYNC_INFO"/>
    <appender-ref ref="ASYNC_DEBUG"/>
    <appender-ref ref="ASYNC_WARN"/>
    <appender-ref ref="ASYNC_ERROR"/>
</logger>

<appender name="WARN" class="ch.qos.logback.core.rolling.RollingFileAppender">
    <filter class="ch.qos.logback.classic.filter.LevelFilter">
        <level>WARN</level>
        <onMatch>ACCEPT</onMatch>
        <onMismatch>DENY</onMismatch>   <!-- 非 WARN 一律拒绝 -->
    </filter>
    <file>${logPath}/log/warn.log</file>
    ...
</appender>
<appender name="INFO" class="ch.qos.logback.core.rolling.RollingFileAppender">
    <filter class="ch.qos.logback.classic.filter.LevelFilter">
        <level>INFO</level>
        <onMatch>ACCEPT</onMatch>
        <onMismatch>DENY</onMismatch>   <!-- WARN 会被拒绝，不进 info.log -->
    </filter>
    ...
</appender>

// LogUtils.java
public interface LogUtils {
    Logger BIZ = LoggerFactory.getLogger("BIZ");
}

@KafkaListener(...)
public void kafkaDeviceEventListen(ConsumerRecord<String, String> record) {
    LogUtils.BIZ.info("监听到设备事件消息 {} ", value);   // ✅ 走 BIZ，写 info.log
    // ...
    saveDeviceEventMessage(...);                            // ⚠️ 内部用 log.warn，走 root
    // ...
    LogUtils.BIZ.info("发送设备事件消息=> {}", ...);        // ✅ 走 BIZ，写 info.log
}

private void saveDeviceEventMessage(...) {
    try {
        deviceEventMessageMapper.insert(po);
    } catch (Exception e) {
        log.warn("保存设备事件到本地表失败 ...", e);          // ❌ 走 root，不写任何文件
    }
}

private void saveDeviceEventMessage(DeviceEventEntity event, String containerId, String businessId) {
    try {
        DeviceEventMessagePO po = new DeviceEventMessagePO();
        po.setMsgServiceBusinessId(businessId);
        // ... set 各字段 ...
        deviceEventMessageMapper.insert(po);
    } catch (DuplicateKeyException e) {
        // 唯一索引冲突：Kafka重复消费或同businessId事件重复推送，属于预期场景，仅告警不阻断
        LogUtils.BIZ.warn("设备事件重复插入(唯一索引冲突), businessId={}, deviceSn={}, eventType={}, occurTime={}",
                businessId, event.getDeviceSn(), event.getEventType(), event.getOccurTime());
    } catch (Exception e) {
        LogUtils.BIZ.warn("保存设备事件到本地表失败, businessId={}, deviceSn={}, eventType={}",
                businessId, event.getDeviceSn(), event.getEventType(), e);
    }
}

<root level="INFO">
    <appender-ref ref="STDOUT"/>
    <appender-ref ref="ASYNC_INFO"/>
    <appender-ref ref="ASYNC_WARN"/>   <!-- 补上这一行 -->
    <appender-ref ref="ASYNC_ERROR"/>
</root>

// ❌ 用 @Slf4j 的 log，走 root logger，warn 不落盘
log.warn("保存设备事件到本地表失败 businessId={}", businessId, e);

// ❌ 异常被吞但无任何日志
} catch (Exception e) {
    // 啥也不干
}