Linux/Mac 部署kafka、Zipkin，Zipkin整合kafka实现链路追踪

目录

一、下载安装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 量