log4j2和kafka集成

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客户端