基于springboot整合kafka+log4j

1.引入依赖

>
    >org.apache.kafka>
    >kafka-log4j-appender>
    >0.10.1.1>
>

2.在resources目录下创建log4j.properties文件。配置如下：

log4j.rootLogger=info, kafka
log4j.logger.into=info
# LogAppender类所在路径
log4j.appender.info=com.hx.kafka.config.LogAppender
log4j.appender.info.layout=org.apache.log4j.PatternLayout
log4j.appender.info.layout.ConversionPattern=%-d{yyyy-MM-dd HH\:mm\:ss} [%p]-[%c]%m%n
log4j.appender.info.Threshold=INFO
log4j.appender.info.append=true
log4j.appender.info.File=/Users/workspace/logs/kafka-log4j-info.log
# 定义一个名为kafka的Appender
log4j.appender.kafka=org.apache.kafka.log4jappender.KafkaLog4jAppender
# 指定日志写入到kafka主题
log4j.appender.kafka.topic=kafka-log4j
# 指定连接kafka的地址
log4j.appender.kafka.brokerList=localhost:9092
# 压缩方式，默认为none
log4j.appender.kafka.compressionType=none
# 指定Producer发送消息的方式
log4j.appender.kafka.syncSend=true
# 指定日志级别
log4j.appender.kafka.Threshold=INFO
log4j.appender.kafka.layout=org.apache.log4j.PatternLayout
log4j.appender.kafka.layout.ConversionPattern=%-d{yyyy-MM-dd HH\:mm\:ss} [%p]-[%c]%m%n

3.创建LogAppender类

public class LogAppender extends DailyRollingFileAppender {
	// 啥也不用干
}

4.创建测试类

public class Log4jProducer {

    private static final Logger log = Logger.getLogger(Log4jProducer.class);

    public static void main(String[] args) {
        log.info("this is level info message");
        log.error("this is level error message");
    }
}

5.在kafka中创建主题

主题名：kafka-log4j ；副本数：1个；分区数：5个

./kafka-topics.sh --zookeeper localhost:2181 --create --topic kafka-log4j --replication-factor 1 --partitions 5

6.看测试效果

6.1 kafka主题创建成功

查看分区文件

6.2先打开kafka-log4j主题消息控制台

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic kafka-log4j

6.3运行main方法
main方法输出：

kafka控制台输出：

参考文档：书籍《kafka入门与实践》