Springboot 链路日志发送kafka

可以通过使用 Spring Cloud Sleuth 和 Spring Cloud Stream 实现在 Spring Boot 应用中将链路日志发送到 Kafka。

首先，在 pom.xml 文件中添加以下依赖：

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>

然后，在 application.yml 文件中配置 Sleuth 和 Kafka：

spring:
  application:
    name: my-application
  sleuth:
    sampler:
      probability: 1.0
  cloud:
    stream:
      kafka:
        binder:
          brokers: localhost:9092
      bindings:
        my-log-output:
          destination: my-topic

接下来，在应用中添加一个 LogMessage 类来表示要发送到 Kafka 的日志信息：

public class LogMessage {
  private String traceId;
  private String spanId;
  private String message;

  // getters and setters
}

然后，在应用中使用 Sleuth 记录链路日志，并将日志信息发送到 Kafka：

@RestController
public class MyController {
  private final Tracer tracer;
  private final MessageChannel myLogOutput;

  public MyController(Tracer tracer, MessageChannel myLogOutput) {
    this.tracer = tracer;
    this.myLogOutput = myLogOutput;
  }

  @GetMapping("/hello")
  public String hello() {
    Span span = this.tracer.nextSpan().name("my-span").start();
    try (Tracer.SpanInScope ws = this.tracer.withSpan(span)) {
      String traceId = span.context().traceIdString();
      String spanId = span.context().spanIdString();
      String message = "Hello, world!";
      LogMessage logMessage = new LogMessage();
      logMessage.setTraceId(traceId);
      logMessage.setSpanId(spanId);
      logMessage.setMessage(message);
      this.myLogOutput.send(new GenericMessage<>(logMessage));
      return message;
    } finally {
      span.end();
    }
  }
}

这样，当应用处理请求时，它将使用 Sleuth 记录链路日志，并将日志信息发送到 Kafka 中的 "my-topic" 主题中。你可以通过消费该主题中的消息来实现对链路日志的监控和分析。