天天看點

Linux/Mac 部署kafka、Zipkin,Zipkin整合kafka實作鍊路追蹤一、下載下傳安裝kafka二、下載下傳并啟動zipkin三、項目中使用:

目錄

一、下載下傳安裝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

Linux/Mac 部署kafka、Zipkin,Zipkin整合kafka實作鍊路追蹤一、下載下傳安裝kafka二、下載下傳并啟動zipkin三、項目中使用:
Linux/Mac 部署kafka、Zipkin,Zipkin整合kafka實作鍊路追蹤一、下載下傳安裝kafka二、下載下傳并啟動zipkin三、項目中使用:
Linux/Mac 部署kafka、Zipkin,Zipkin整合kafka實作鍊路追蹤一、下載下傳安裝kafka二、下載下傳并啟動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 量