前言

承接上文( 微服务日志之.NET Core使用NLog通过Kafka实现日志收集 https://www.cnblogs.com/maxzhang1985/p/9522017.html ).NET/Core的实现,我们的目地是为了让微服务环境中dotnet和java的服务都统一的进行日志收集。
Java体系下Spring Boot + Logback很容易就接入了Kafka实现了日志收集。

Spring Boot集成

Maven 包管理

<dependencyManagement>   <dependencies>      <dependency>     <groupId>ch.qos.logback</groupId>     <artifactId>logback-core</artifactId>     <version>1.2.3</version>     </dependency>   </dependencies> </dependencyManagement>

包依赖引用:

<dependency>     <groupId>com.github.danielwegener</groupId>     <artifactId>logback-kafka-appender</artifactId>     <version>0.2.0-RC1</version> </dependency> <dependency>     <groupId>ch.qos.logback</groupId>     <artifactId>logback-classic</artifactId>     <version>1.2.3</version>     <scope>runtime</scope> </dependency> <dependency>     <groupId>net.logstash.logback</groupId>     <artifactId>logstash-logback-encoder</artifactId>     <version>5.0</version> </dependency>

logback-spring.xml

在Spring Boot项目resources目录下添加logback-spring.xml配置文件，注意：一定要修改 {"appname":"webdemo"}，这个值也可以在配置中设置为变量。添加如下配置，STDOUT是在连接失败时，使用的日志输出配置。所以这每个项目要根据自己的情况添加配置。在普通日志输出中使用异步策略提高性能，内容如下:

 <appender name="kafkaAppender" class="com.github.danielwegener.logback.kafka.KafkaAppender">         <encoder charset=

                    

                        
关键字：