如何通过Log4j2-elasticsearch-hc异步Logger将JSON对象以键值对写入ES索引

1. 自定义消息转换器（推荐方案） #

直接传递POJO时，Log4j2默认会调用toString()将其转为字符串存入message字段。你可以自定义一个消息转换器，让Log4j2能解析POJO并提取键值对：

• 实现org.apache.logging.log4j.core.pattern.LogEventPatternConverter接口，在format方法中解析POJO实例，将其字段转为JSON结构
• 在log4j2.xml的JsonLayout中配置该转换器，替换默认的消息处理逻辑
• 示例配置片段：

<Layout type="JsonLayout">
    <PatternLayout>
        <Pattern>%customPojoConverter{%message}</Pattern>
    </PatternLayout>
</Layout>

（注：customPojoConverter是你自定义转换器的名称，需提前在配置中注册该转换器）

2. 改用结构化日志API传递字段 #

避免直接传递POJO实例，改用Log4j2原生的结构化日志方式：

• 将POJO的字段拆解后，用logger.info("{}", Map.of("fieldA", pojo.getFieldA(), "fieldB", pojo.getFieldB()))传递，或使用StructuredDataMessage封装字段
• 配合JsonLayout的complete="true"和compact="false"配置，让这些字段直接成为Elasticsearch文档的顶级字段
• 此方案无需自定义类，AsyncLogger可正常处理上下文传递

3. 利用JsonLayout的ObjectMessage解析功能 #

Log4j2的JsonLayout支持将ObjectMessage直接转为JSON对象：

• 发送日志时，将POJO包装为ObjectMessage：logger.info(new ObjectMessage(pojo))
• 在log4j2.xml的JsonLayout中开启objectMessageAsJsonObject="true"参数
• 示例配置：

<Layout type="JsonLayout" objectMessageAsJsonObject="true" complete="true" />

开启后，POJO的字段会自动展开为Elasticsearch文档的顶级键值对，而非存入message字段

4. 修复ThreadContext在AsyncLogger中的传递问题 #

VirtualProperty在AsyncLogger中失效是因为异步线程上下文未正确传递，可改用以下方式：

• 在主线程中将POJO字段存入ThreadContext：ThreadContext.put("fieldX", pojo.getFieldX())
• 在JsonLayout中开启includeContext="true"，确保上下文字段被写入日志
• 在AsyncLogger配置中设置includeLocation="true"，保证线程上下文能传递到异步线程
• 此方案适合字段较少的场景，字段过多时操作繁琐

额外注意事项 #

• 确保Elasticsearch索引的映射配置正确，避免字段被自动映射为text类型导致查询困难
• 测试阶段可先用ConsoleAppender配合JsonLayout输出日志，确认结构化格式无误后再写入Elasticsearch

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