- 使用步骤
1.导入.pom 依赖
<dependency>
<groupId>org.springframework.cloudgroupId>
<artifactId>spring-cloud-starter-zipkinartifactId>
dependency>
<dependency>
<groupId>org.springframework.kafkagroupId>
<artifactId>spring-kafkaartifactId>
<version>2.5.0.RELEASEversion>
dependency>
2.启动kafka
这里不是讨论的重点,就默认启动方法就行,在kafka官网的快速开始可以找到。
3.在 https://zipkin.io/官网下载对应版本的jar并编写启动.sh脚本
java -DKAFKA_BOOTSTRAP_SERVERS=127.0.0.1:9092 -jar zipkin-server-2.21.7-exec.jar --STORAGE_TYPE=mysql --MYSQL_DB=imooc_zipkin --MYSQL_USER=root --MYSQL_PASS=123456
其中每个参数如何配置在 zipkin-server.readme.md可以知道每个参数的意义
4.编写配置文件:
kafka:
bootstrap-servers: 127.0.0.1:9092
producer:
retries: 3
consumer:
auto-offset-reset: latest
sleuth:
sampler:
# ProbabilityBasedSampler 抽样策略
probability: 1.0 # 采样比例, 1.0 表示 100%, 默认是 0.1
# RateLimitingSampler 抽样策略, 设置了限速采集, spring.sleuth.sampler.probability 属性值无效
rate: 100 # 每秒间隔接受的 trace 量
zipkin:
sender:
type: kafka # 默认是 web
base-url: http://localhost:9411/
流程就是这样。仅记录学习笔记。具体原理不够了解就不概述。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)