Kafka Log4j2 Appender不发送最后一条日志事件，求无需生成虚拟日志的解决方案

这个现象是Kafka生产者默认的批量发送优化机制导致的：Kafka生产者默认会将多条消息攒到同一个批次，等批次大小达到阈值或者等待超时后才会统一发送到服务端。你的最后一条日志生成后，既没有达到默认的批次大小阈值，也没有触发等待超时，就会一直滞留在本地缓冲区，直到下一条日志生成凑够触发条件，才会连同之前滞留的日志一起发送。

下面三种方案可根据业务场景选择：

• 方案1：启用同步发送（适合日志量较小的场景）
  直接修改Log4j2配置，给Kafka Appender添加syncSend属性，设置为true后每条日志都会直接同步发送到Kafka，不会本地攒批，配置如下：

appender.kafka.syncSend = true

• 方案2：调整Kafka生产者批量参数（兼顾性能和实时性）
  如果担心同步发送影响性能，可以调低批次等待超时时间和批次大小阈值，让缓冲区的消息最多等待几毫秒就会发送，不用等新日志触发，配置如下：

# 消息最多滞留5ms就发送，单位毫秒
appender.kafka.lingerMs.type=Property
appender.kafka.lingerMs.name=linger.ms
appender.kafka.lingerMs.value=5
# 批次大小调整为16KB，可根据实际日志大小调整，单位字节
appender.kafka.batchSize.type=Property
appender.kafka.batchSize.name=batch.size
appender.kafka.batchSize.value=16384

• 方案3：确保应用优雅关闭
  如果你的日志丢失只发生在应用停止阶段，需要确保应用退出时会触发Log4j2上下文的优雅关闭，关闭时会自动flush Kafka缓冲区里的所有未发送消息。普通Java应用可在退出逻辑中调用org.apache.logging.log4j.core.config.Configurator.shutdown()方法触发关闭，大部分上层框架（如Spring Boot）默认已经内置了该逻辑，只要不用kill -9强制终止进程即可。

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