openzipkincontrib/zipkin-storage-kafka

Zipkin Storage: Kafka（实验性）

镜像概述

这是一个基于Kafka的Zipkin存储模块，用于处理分布式系统中的追踪数据。它将收集到的spans通过Kafka进行分区、聚合，生成traces和依赖关系，并支持Zipkin的查询与搜索接口，适用于需要实时追踪分析的场景。

核心功能

• 基于Kafka存储追踪spans，按traceId分区
• 实时聚合spans为traces和依赖关系
• 支持Zipkin的查询API（如获取traces、服务名、依赖图等）
• 可配置不同运行模式（如仅依赖分析模式）
• 兼容多种数据传输方式（HTTP、Kafka、AMQ等）

使用场景

1. 替代批处理依赖分析：解决传统zipkin-dependencies模块的批处理延迟问题，实现实时依赖关系计算。
2. 分布式部署：将分区、聚合与存储功能拆分到不同容器，适应大规模系统。
3. 单节点测试：快速搭建本地环境，验证追踪数据的存储与查询。

配置说明

• 启用仅依赖分析模式：设置环境变量 MODULE_OPTS="-Dloader.path=lib -Dspring.profiles.active=kafka-only-dependencies"
• Kafka配置：确保Kafka broker地址正确（默认localhost:***），并创建所需主题（可通过make kafka-topics生成）。

部署示例

Docker Run命令

bash
docker run -d \
  -e MODULE_OPTS="-Dloader.path=lib -Dspring.profiles.active=kafka-only-dependencies" \
  -e KAFKA_BOOTSTRAP_SERVERS=kafka:9092 \
  docker.xuanyuan.run/openzipkincontrib/zipkin-storage-kafka

Docker Compose示例（单节点）

yaml
version: '3'
services:
  kafka:
    image: confluentinc/cp-kafka:7.3.0
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    depends_on:
      - zookeeper
  zookeeper:
    image: confluentinc/cp-zookeeper:7.3.0
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
  zipkin-storage-kafka:
    image: openzipkincontrib/zipkin-storage-kafka
    environment:
      MODULE_OPTS: "-Dloader.path=lib -Dspring.profiles.active=kafka-only-dependencies"
      KAFKA_BOOTSTRAP_SERVERS: kafka:9092
    ports:
      - "9411:9411"
    depends_on:
      - kafka