我要评论1.maven依赖
<dependency>
<groupid>com.github.danielwegener</groupid>
<artifactid>logback-kafka-appender</artifactid>
<version>0.2.0-rc2</version>
</dependency>
<dependency>
<groupid>net.logstash.logback</groupid>
<artifactid>logstash-logback-encoder</artifactid>
<version>6.4</version>
</dependency>
<dependency>
<groupid>ch.qos.logback</groupid>
<artifactid>logback-classic</artifactid>
<version>1.2.3</version>
</dependency>2.logback-spring.xml中增加以下内容
<springproperty scope="context" name="service" source="spring.application.name" defaultvalue="unknownservice"/>
<springproperty scope="context" name="env" source="elk.env" defaultvalue="test"/>
<springproperty scope="context" name="bootstrapservers" source="elk.kafka.bootstrap.servers" defaultvalue="localhost:9092"/>
<!--以上三行需要和yml对应-->
<appender name="kafkaappender" class="com.github.danielwegener.logback.kafka.kafkaappender">
<encoder class="net.logstash.logback.encoder.loggingeventcompositejsonencoder">
<providers class="net.logstash.logback.composite.loggingevent.loggingeventjsonproviders">
<pattern>
<pattern>
{
"env": "${env}",
"service":"${service}",
"date":"%d{yyyy-mm-dd hh:mm:ss.sss}",
"level":"%level",
"thread": "%thread",
"logger": "%logger{36}",
"msg":"%msg",
"exception":"%exception"
}
</pattern>
</pattern>
</providers>
</encoder>
<topic>msa-log-${env}</topic>
<keyingstrategy class="com.github.danielwegener.logback.kafka.keying.nokeykeyingstrategy"/>
<deliverystrategy class="com.github.danielwegener.logback.kafka.delivery.asynchronousdeliverystrategy"/>
<producerconfig>acks=0</producerconfig>
<producerconfig>linger.ms=1000</producerconfig>
<producerconfig>max.block.ms=0</producerconfig>
<producerconfig>bootstrap.servers=${bootstrapservers}</producerconfig>
</appender>
<appender name="async" class="ch.qos.logback.classic.asyncappender">
<appender-ref ref="kafkaappender"/>
</appender>
<root level="info">
<appender-ref ref="async"/>
</root>3.参考
https://github.com/danielwegener/logback-kafka-appender
到此这篇关于logback如何将日志输出到kafka配置示例的文章就介绍到这了,更多相关logback日志输出到kafka内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论