如何通过kafka发送trace ID

Question

微服务1->卡夫卡->微服务2 传输数据时如何传递跟踪 ID？ 我正在使用 spring sleuth 来制作跟踪 ID。 我正在使用“编译（'org.springframework.kafka:spring-kafka:2.1.2.RELEASE'）”

Answer 1

请阅读文档https://cloud.spring.io/spring-cloud-static/Finchley.SR2/single/spring-cloud.html#_sleuth_with_zipkin_over_rabbitmq_or_kafka

48.3.3 在 RabbitMQ 或 Kafka 上使用 Zipkin 进行侦探如果您想使用 RabbitMQ 或 Kafka 而不是 HTTP，请添加 spring-rabbit 或 spring-kafka 依赖。默认目标名称是 zipkin。

如果使用 Kafka，则必须设置属性 spring.zipkin.sender.type 相应的属性：

spring.zipkin.sender.type: kafka [注意] 注意 spring-cloud-sleuth-stream 已弃用且与这些不兼容 目的地。

如果你想要 Sleuth over RabbitMQ，添加 spring-cloud-starter-zipkin 和 spring-rabbit 依赖项。

以下示例显示了如何为 Gradle 执行此操作：

马文。

<dependencyManagement> 1
       <dependencies>
           <dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-dependencies</artifactId>
               <version>${release.train.version}</version>
               <type>pom</type>
               <scope>import</scope>
           </dependency>
       </dependencies> </dependencyManagement>

 <dependency> 2
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-zipkin</artifactId> </dependency> <dependency> 3
     <groupId>org.springframework.amqp</groupId>
     <artifactId>spring-rabbit</artifactId> </dependency> 1

我们建议您通过 Spring 添加依赖管理 BOM，因此您无需自己管理版本。

2

将依赖添加到 spring-cloud-starter-zipkin。这样一来，所有 嵌套的依赖被下载。

3

要自动配置 RabbitMQ，请添加 spring-rabbit 依赖。

分级。

dependencyManagement { 1
     imports {
         mavenBom "org.springframework.cloud:spring-cloud-dependencies:${releaseTrainVersion}"
     } }

 dependencies {
     compile "org.springframework.cloud:spring-cloud-starter-zipkin" 2
     compile "org.springframework.amqp:spring-rabbit" 3 } 1

我们建议您通过 Spring 添加依赖管理 BOM，因此您无需自己管理版本。

2

将依赖添加到 spring-cloud-starter-zipkin。这样一来，所有 嵌套的依赖被下载。

3

要自动配置 RabbitMQ，请添加 spring-rabbit 依赖。