Spring Boot2 集成 logback kafkaAppender输出日志到kafka

╰半夏微凉° 2022-12-26 11:16 347阅读 0赞

在实际开发工作中，微服务日志收集、安全日志上报等功能是志在必行的功能，以下就是一种日志上报方式。参考 [https://github.com/danielwegener/logback-kafka-appender][https_github.com_danielwegener_logback-kafka-appender]

1.使用maven引入所需要的jar包

<dependency>
                <groupId>com.github.danielwegener</groupId>
                <artifactId>logback-kafka-appender</artifactId>
               	<version>0.2.0-RC2</version>
            </dependency>
    
    		<dependency>
    			<groupId>ch.qos.logback</groupId>
    			<artifactId>logback-classic</artifactId>
    			<version>1.2.3</version>
    			<scope>runtime</scope>
    		</dependency>

2.application.properties文件添加一下配置

# kafka配置
    spring.kafka.appender.bootstrap.servers=localhost:9092
    spring.kafka.appender.topic=test

3.修改logback.xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <configuration>
        
        <property name="log.path" value="/mnt/logs" />
        
        <property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - [%method,%line] - %msg%n" />
        
        <springProperty scope="context" name="kafka.servers" source="spring.kafka.appender.bootstrap.servers"/>-->
        <springProperty scope="context" name="kafka.topic" source="spring.kafka.appender.topic"/>
        
        <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
            <encoder>
                <pattern>%black %red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta(%logger) - %cyan(%msg%n)</pattern>
            </encoder>
        </appender>
    
        
        <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
            <file>${log.path}/logger.log</file>
            
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
                
                <fileNamePattern>${log.path}/logger.%d{yyyy-MM-dd}.log</fileNamePattern>
                
                <maxHistory>30</maxHistory>
            </rollingPolicy>
            <encoder>
                <pattern>%black %red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta(%logger) - %cyan(%msg%n)</pattern>
            </encoder>
        </appender>
    
        
        <appender name="kafkaAppender" class="com.github.danielwegener.logback.kafka.KafkaAppender">
            <encoder>
                <pattern>
                    {
                    "service":"${kafka.servers}",
                    "date":"%d{yyyy-MM-dd HH:mm:ss}",
                    "level":"%level",
                    "thread": "%thread",
                    "logger": "%logger{36}",
                    "msg":"%msg"
                    }
                </pattern>
            </encoder>
            
            <topic>${kafka.topic}</topic>
            
            <keyingStrategy class="com.github.danielwegener.logback.kafka.keying.NoKeyKeyingStrategy" />
            <deliveryStrategy class="com.github.danielwegener.logback.kafka.delivery.AsynchronousDeliveryStrategy" />
            
            <producerConfig>bootstrap.servers=${kafka.servers}</producerConfig>
        </appender>
    
        
        <appender name="Async" class="ch.qos.logback.classic.AsyncAppender">
            <appender-ref ref="kafkaAppender" />
        </appender>
    
        
        <root level="info">
            <appender-ref ref="console" />
            <appender-ref ref="file" />
            <appender-ref ref="Async" />
        </root>
    
    </configuration>

[https_github.com_danielwegener_logback-kafka-appender]: https://github.com/danielwegener/logback-kafka-appender