log4j2依赖
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-web</artifactId>
<version>2.4</version>
<scope>runtime</scope>
</dependency>
kafka 依赖
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.2.0</version>
</dependency>
log4j2.xml
1 <?xml version="1.0" encoding="UTF-8"?>
2 <Configuration status="warn" name="MyApp" packages="">
3 <Appenders>
4 <Console name="STDOUT" target="SYSTEM_OUT">
5 <PatternLayout pattern="%d %p %c{1.} [%t] %m%n"/>
6 </Console>
7 <Kafka name="Kafka" topic="log-test">
8 <PatternLayout pattern="%date %message"/>
9 <Property name="bootstrap.servers">192.168.194.110:9092</Property>
10 </Kafka>
11 </Appenders>
12 <Loggers>
13 <Root level="trace">
14 <AppenderRef ref="STDOUT"/>
15 <AppenderRef ref="Kafka"/>
16 </Root>
17 </Loggers>
18 </Configuration>
Main.java
1 import org.apache.logging.log4j.LogManager;
2 import org.apache.logging.log4j.Logger;
3
4 public class Main {
5 private static final Logger logger = LogManager.getLogger(Main.class);
6
7 public static void main(String[] args) {
8 logger.info("Hello log4j!!!");
9 }
10
11 }
12
控制台：
kafka客户端
log4j2和kafka集成
原文：http://www.cnblogs.com/hxy520/p/4849865.html
