如何通过kafka发送跟踪id

3yhwsihp  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(478)

microservice1->kafka->microservice2传输数据时如何传递跟踪id?我使用springsleuth生成跟踪id,我使用“compile('org.springframework。kafka:spring-kafka:2.1.2.释放“)”

sy5wg1nm

sy5wg1nm1#

请看文件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进行sleuth如果要使用rabbitmq或kafka而不是http,请添加spring rabbit或spring kafka依赖项。默认的目标名称是zipkin。
如果使用kafka,则必须相应地设置spring.zipkin.sender.type属性:
spring.zipkin.sender.type:kafka[caution]caution spring cloud sleuth stream已弃用,并且与这些目标不兼容。
如果您希望sleuth胜过rabbitmq,请添加springcloudstarterzipkin和springrabbit依赖项。
下面的示例演示如何为gradle执行此操作:
Maven。

<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

我们建议您通过springbom添加依赖项管理,这样您就不需要自己管理版本了。
2
将依赖项添加到spring cloud starter zipkin。这样,就可以下载所有嵌套的依赖项。

要自动配置rabbitmq,请添加springrabbit依赖项。
grad尔。

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

我们建议您通过springbom添加依赖项管理,这样您就不需要自己管理版本了。
2
将依赖项添加到spring cloud starter zipkin。这样,就可以下载所有嵌套的依赖项。

要自动配置rabbitmq,请添加springrabbit依赖项。

相关问题