使用Log4j2 json配置Kafka Appender

Question

我将log4j2与一个JSON属性文件一起使用，我将其命名为log4j2。json并尝试添加Kafka追加器。有很多使用旧格式或xml的示例，但很难在JSON中获得正确的格式。这很可能是一个愚蠢的问题，但我一直在努力让它发挥作用，在任何地方都找不到任何例子。我很想放弃在json中配置log4j2，转而使用XML，但我觉得这应该相当简单。

这是一个用XML定义的示例kafka appender。

'<Appenders>
    <Kafka name="Kafka" topic="devglan-test">
        <PatternLayout pattern="%date %message"/>
        <Property name="bootstrap.servers">localhost:9092</Property>
    </Kafka>
    <Async name="Async">
        <AppenderRef ref="Kafka"/>
    </Async>
</Appenders>

localhost:9092条目如何映射到JSON。

那不起作用。我也试过...

'"Kafka": {
            "name":"Kafka",
            "topic":"FEEDPROCESSING_SYNC_Dev",
            "PatternLayout": {
                "pattern": "%date %message"
            },
    "Property": {"bootstrap.servers":"localhost:9092"}}
}

我得到这样的错误：属性包含无效的元素或属性"bootstrap.servers"

此配置导致错误“无法定位引导服务器的插件类型”：

'"Property": {"bootstrap.servers":[{"name":"localhost:9092"}]}}},

我知道我有正确的maven依赖项。。

使用JSON和log4j2配置Kafka appender，特别是bootstrap server属性的正确方法是什么？

Answer 1

这是我认为正确的格式：

"Kafka": {
    "name": "Kafka",
    "topic": "FEEDPROCESSING_Dev",
    "PatternLayout": {
        "pattern": "%date %message"
    },
    "Property": {
        "name": "bootstrap.servers",
        "value": "localhost:9092"
    }
}