如何在Log4j2 Kafka Appender的JSON配置中配置syncSend属性？

问题原因 #

你遇到的ERROR Kafka contains an invalid element or attribute "syncSend"错误，是因为Log4j 2的Kafka Appender并不支持syncSend这个配置属性——这个属性属于Logback框架的Kafka Appender，混淆配置框架导致了报错。

正确的异步配置方案 #

Log4j 2实现日志异步推送Kafka的标准方式是用AsyncAppender包裹Kafka Appender，而非添加不存在的syncSend属性。具体修改步骤如下：

1. 移除无效配置 #

首先删除Kafka Appender配置中的"syncSend": "false"行，恢复基础的Kafka Appender配置。

2. 添加AsyncAppender包装 #

在配置中新增一个Async类型的Appender，将Kafka Appender作为它的目标Appender，实现异步发送逻辑。

修改后的完整配置示例：

{
  "configuration": {
    "appenders": {
      "Kafka": {
        "name": "Kafka",
        "type": "Kafka",
        "topic": "api.logs",
        "PatternLayout": {
          "pattern": "%d{yyyy-MM-dd HH:mm:ss} %C.%M:%L - %X{dd.trace_id} %X{dd.span_id} %m%n"
        },
        "property": [
          {
            "name": "bootstrap.servers",
            "value": "bootstrapserver1, bootstrapserver2 ... "
          },
          {
            "name": "linger.ms",
            "value": "5"
          },
          {
            "name": "batch.size",
            "value": "16384"
          }
        ]
      },
      "AsyncKafka": {
        "name": "AsyncKafka",
        "type": "Async",
        "appender-ref": {
          "ref": "Kafka"
        },
        // 可选配置：调整缓冲区大小，满时是否阻塞主线程
        "bufferSize": "1024",
        "blocking": "false"
      }
    },
    "loggers": {
      "root": {
        "level": "info",
        "appender-ref": {
          "ref": "AsyncKafka"
        }
      }
    }
  }
}

3. 关键配置说明 #

• bufferSize：设置异步日志缓冲区的大小，默认1024，可根据业务日志量调整。
• blocking：设为false时，缓冲区满时会丢弃新日志（避免阻塞业务线程）；设为true时会阻塞直到缓冲区有空间，可根据业务容错需求选择。
• 确保log4j-kafka-appender依赖版本与Log4j 2核心版本一致，避免版本冲突。

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