目录
2、进入kafka目录、启动ZK和Kafka Server即可(使用默认配置)
3.2、持久化启动 (参数依次为:持久化数据库类型、ip、端口、账号、密码、数据库名称):
一、下载安装kafka
1、下载kafka
下载地址:https://kafka.apache.org/downloads
2、进入kafka目录、启动ZK和Kafka Server即可(使用默认配置)
启动ZK命令:bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka命令:bin/kafka-server-start.sh config/server.properties
二、下载并启动zipkin
1、下载zipkin
2、启动zipkin
启动命令:前台启动(java -jar zipkin.jar) 后台启动(nohup java -jar zipkin.jar &)
3、持久化配置
3.1、下载mysql脚本,并导入数据库
脚本下载地址:zipkin/zipkin-storage/mysql-v1/src/main/resources at master · openzipkin/zipkin · GitHub
3.2、持久化启动 (参数依次为:持久化数据库类型、ip、端口、账号、密码、数据库名称):
java -jar zipkin.jar --STORAGE_TYPE=mysql --MYSQL_HOST=127.0.0.1 --MYSQL_TCP_PORT=3306 --MYSQL_USER=root --MYSQL_PASS=zkc2002318 --MYSQL_DB=
zipkin
4、zipkin整合kafka启动命令
java -DKAFKA_BOOTSTRAP_SERVERS=127.0.0.1:9092 -jar zipkin.jar --STORAGE_TYPE=mysql --MYSQL_HOST=127.0.0.1 --MYSQL_TCP_PORT=3306 --MYSQL_USER=root --MYSQL_PASS=zkc2002318 --MYSQL_DB=zipkin
三、项目中使用:
1、引入kafka、zipkin依赖
<!-- zipkin = spring-cloud-starter-sleuth + spring-cloud-sleuth-zipkin-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.5.0.RELEASE</version>
</dependency>
2、配置文件配置:
kafka:
bootstrap-servers: 127.0.0.1:9092
producer:
retries: 3
consumer:
auto-offset-reset: latest
zipkin:
base-url: http://127.0.0.1:8087/
discoveryClientEnabled: false
sender:
type: kafka
sleuth:
sampler:
# ProbabilityBasedSampler 抽样策略
probability: 1.0 #采样 比例,1.0表示 100% 默认为0.1
# RateLimitingSampler 抽样策略,设置了限速采集,spring.sleuth.sampler.probability 属性无效
# rate: 100 # 每秒间隔接受的trace 量