log4j2.xml
如下圖，13-17行內配置kafka信息，以及id名字，在35行輸出日志，在43行選擇日志格式
1 <?xml version="1.0" encoding="UTF-8"?> 2 <!--設置log4j2的自身log級別為warn--> 3 <!--日志級別以及優先級排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL --> 4 <!--Configuration后面的status，這個用於設置log4j2自身內部的信息輸出，可以不設置， 5 當設置成trace時，你會看到log4j2內部各種詳細輸出--> 6 <!--monitorInterval：Log4j能夠自動檢測修改配置 文件和重新配置本身，設置間隔秒數--> 7 <configuration status="info" monitorInterval="30" > 8 <Properties> 9 <Property name="log.basepath"></Property> 10 </Properties> 11 <!--先定義所有的appender--> 12 <appenders> 13 <Kafka name="KafkaTraceLog" topic="apm"> 14 <PatternLayout pattern="%msg"/> 15 <Property name="bootstrap.servers">10.20.30.33:9092</Property> 16 <Property name="batch.size">16384</Property> 17 </Kafka> 18 <!--這個輸出控制台的配置--> 19 <console name="Console" target="SYSTEM_OUT"> 20 <!--輸出日志的格式--> 21 <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/> 22 </console> 23 <!-- 這個會打印出所有的info及以下級別的信息，每次大小超過size， 24 則這size大小的日志會自動存入按年份-月份建立的文件夾下面並進行壓縮，作為存檔--> 25 <RollingFile name="RollingFileInfo" fileName="${log.basepath}dataapilogs/bdata.log" 26 filePattern="${log.basepath}dataapilogs/bdata-%d{yyyy-MM-dd}-%i.log"> 27 <PatternLayout pattern="[%d{yyyy-MM-dd HH:mm:ss:SSS}] [%p] - %l - %m%n"/> 28 <Policies> 29 <TimeBasedTriggeringPolicy interval="30"/> 30 <SizeBasedTriggeringPolicy size="500MB"/> 31 </Policies> 32 </RollingFile> 33 <Async name="AsyncRollingFileInfo"> 34 <AppenderRef ref="RollingFileInfo" /> 35 <AppenderRef ref="KafkaTraceLog" /> 36 </Async> 37 </appenders> 38 <!--然后定義logger，只有定義了logger並引入的appender，appender才會生效--> 39 <loggers> 40 <root level="info"> 41 <appender-ref ref="Console"/> 42 <appender-ref ref="RollingFileInfo"/> 43 <appender-ref ref="KafkaTraceLog" /> 44 45 </root> 46 47 </loggers> 48 </configuration>
需要添加依賴
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.2.0</version> </dependency>