目錄
一、下載下傳安裝kafka
1、下載下傳kafka
2、進入kafka目錄、啟動ZK和Kafka Server即可(使用預設配置)
二、下載下傳并啟動zipkin
1、下載下傳zipkin
2、啟動zipkin
3、持久化配置
3.1、下載下傳mysql腳本,并導入資料庫
3.2、持久化啟動 (參數依次為:持久化資料庫類型、ip、端口、賬号、密碼、資料庫名稱):
4、zipkin整合kafka啟動指令
三、項目中使用:
1、引入kafka、zipkin依賴
2、配置檔案配置:
一、下載下傳安裝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
下載下傳位址:Quickstart · OpenZipkin
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 量