log4j 自定义 Kafka appender 并使用

log4j是一个广泛使用的日志框架，它允许开发者自定义日志记录的方式，包括将日志消息发送到特定的输出目的地，如Kafka。要自定义一个Kafka Appender，你需要按照以下步骤操作：

1. **添加依赖**：首先，在你的项目中引入log4j及其对Kafka的支持库，例如`log4j-core`和`log4j-kafka`。

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-api</artifactId>
    <version>2.x.x</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.x.x</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-kafka</artifactId>
    <version>2.x.x</version>
</dependency>

2. **配置Log4j**：创建一个XML或YAML配置文件，配置一个名为`kafka`的日志appender，并指定Kafka的连接信息，如bootstrap servers、topic名等。

<!-- XML配置示例 -->
<Configuration status="WARN">
    <Appenders>
        <Kafka name="MyKafkaAppender" topicName="my-app-log-topic"
               brokers="localhost:9092" batchSize="100" />
    </Appenders>
    <Loggers>
        <Root level="info">
            <AppenderRef ref="MyKafkaAppender" />
        </Root>
    </Loggers>
</Configuration>

3. **编写Appender实现**：实现`Log4jKafkaAppender`接口或者继承`AbstractKafkaAppender`，覆盖必要的方法如`formatMessage()`，用于构造要发布的日志消息。

4. **启动应用并使用**：启动你的应用，现在每次日志事件发生时，log4j会自动将消息通过你定制的Kafka Appender发送到指定的Kafka主题。

import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.core.appender.KafkaAppender;

public class MyClass {
    private static final Logger logger = LogManager.getLogger(MyClass.class);
    
    public void myMethod() {
        logger.info("This is a custom Kafka log message");
    }
}