• 部署ZK

  docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
  

• 部署Kafka

  	docker run -d --name xdclass_kafka \
  	-p 9092:9092 \
  	-e KAFKA_BROKER_ID=0 \
  	--env KAFKA_HEAP_OPTS=-Xmx256M \
  	--env KAFKA_HEAP_OPTS=-Xms128M \
  	-e KAFKA_ZOOKEEPER_CONNECT=[内网ip]:2181 \
  	-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://[外网ip]:9092 \
  	-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka:2.13-2.7.0
  

• 采用Slf4j采集日志（lombok）

• 需求

  • 控制台输出访问日志，方便测试
  • 业务数据实际输出到kafka
  • 常用的框架 log4j、logback、self4j等

• log4j、logback、self4j 之间有啥关系

  • SLF4J(Simple logging Facade for Java) 门面设计模式 |外观设计模式

    • 把不同的日志系统的实现进行了具体的抽象化，提供统一的日志使用接口

    • 具体的日志系统就有log4j,logback等；

    • logback也是log4j的作者完成的，有更好的特性，可以取代log4j的一个日志框架, 是slf4j的原生实现

    • log4j、logback可以单独的使用，也可以绑定slf4j一起使用

  • 编码规范建议不直接用log4j、logback的API，应该用self4j, 日后更换框架所带来的成本就很低

• 依赖引入

  <!-- 代码自动生成依赖 end-->
  <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
  </dependency>
  <!--Springboot项目整合spring-kafka依赖包配置-->
  <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
  </dependency>
  

• kafka配置application.properties

  #----------kafka配置--------------
  spring.kafka.bootstrap-servers=[外网ip]:9092
  spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
  spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
  

• logback.xml配置

  <?xml version="1.0" encoding="UTF-8"?>
  <configuration>
      <property name="LOG_HOME" value="./data/logs/link" />
  
      <!--采用打印到控制台，记录日志的方式-->
      <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
          <encoder>
              <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n</pattern>
          </encoder>
      </appender>
  
      <!-- 采用保存到日志文件 记录日志的方式-->
      <appender name="rollingFile" class="ch.qos.logback.core.rolling.RollingFileAppender">
          <file>${LOG_HOME}/link.log</file>
          <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
              <fileNamePattern>${LOG_HOME}/link-%d{yyyy-MM-dd}.log</fileNamePattern>
          </rollingPolicy>
          <encoder>
              <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n</pattern>
          </encoder>
      </appender>
  
  
      <!-- 指定某个类单独打印日志 -->
      <logger name="net.xdclass.service.impl.LogServiceImpl"
              level="INFO" additivity="false">
          <appender-ref ref="rollingFile" />
          <appender-ref ref="console" />
      </logger>
  
      <root level="info" additivity="false">
          <appender-ref ref="console" />
      </root>
  
  </configuration>
  

• LogServiceImpl

  @Service
  @Slf4j
  public class LogServiceImpl implements LogService {
  	
  	// Kafka：topic
      private static final String TOPIC_NAME = "ods_link_visit_topic";
  
      @Autowired
      private KafkaTemplate kafkaTemplate;
  
      /**
       * 记录日志
       *
       * @param request
       * @param shortLi