java日志输出到kafka
生活随笔
收集整理的這篇文章主要介紹了
java日志输出到kafka
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
log4j2.xml
如下圖,13-17行內(nèi)配置kafka信息,以及id名字,在35行輸出日志,在43行選擇日志格式
1 <?xml version="1.0" encoding="UTF-8"?> 2 <!--設(shè)置log4j2的自身log級(jí)別為warn--> 3 <!--日志級(jí)別以及優(yōu)先級(jí)排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL --> 4 <!--Configuration后面的status,這個(gè)用于設(shè)置log4j2自身內(nèi)部的信息輸出,可以不設(shè)置, 5 當(dāng)設(shè)置成trace時(shí),你會(huì)看到log4j2內(nèi)部各種詳細(xì)輸出--> 6 <!--monitorInterval:Log4j能夠自動(dòng)檢測(cè)修改配置 文件和重新配置本身,設(shè)置間隔秒數(shù)--> 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 <!--這個(gè)輸出控制臺(tái)的配置--> 19 <console name="Console" target="SYSTEM_OUT"> 20 <!--輸出日志的格式--> 21 <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/> 22 </console> 23 <!-- 這個(gè)會(huì)打印出所有的info及以下級(jí)別的信息,每次大小超過size, 24 則這size大小的日志會(huì)自動(dòng)存入按年份-月份建立的文件夾下面并進(jìn)行壓縮,作為存檔--> 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才會(huì)生效--> 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>?
轉(zhuǎn)載于:https://www.cnblogs.com/dadddd/p/11435785.html
總結(jié)
以上是生活随笔為你收集整理的java日志输出到kafka的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: jps查看java进程以及pwdx通过p
- 下一篇: 华为RH2288V3服务器部署指南