Kafka
- 支持的 Kafka 版本:3.x
Kafka 可以用作 collector 和实际存储之间的中间缓冲区。Jaeger 可以配置为既充当将跟踪数据导出到 Kafka topic 的 collector,也充当从 Kafka 读取数据并将其写入存储后端的 ingester。
flowchart LR A(应用) --> C@{ shape: procs, label: "Jaeger 采集器"} C --> K@{ img: "/img/kafka.png", w: 120, h: 60 } K --> I@{ shape: procs, label: "Jaeger 注入器"} I --> S[(存储)] style C fill:#9AEBFE,color:black style I fill:#9AEBFE,color:black
将数据写入 Kafka 对于构建后处理数据管道特别有用。
flowchart LR A(应用) --> C@{ shape: procs, label: "Jaeger 采集器"} C --> K@{ img: "/img/kafka.png", w: 120, h: 60 } K --> I@{ shape: procs, label: "Jaeger 注入器"} I --> S[(存储)] K --> P@{ shape: stadium, label: "后处理" } style C fill:#9AEBFE,color:black style I fill:#9AEBFE,color:black
社区还提供以下官方支持的 Kafka 资源:
配置
请参考以下示例配置文件:
Jaeger 使用来自 opentelemetry-collector-contrib
仓库的 Kafka exporter 和 receiver。有关配置详情,请参考它们各自的 README 文件。
主题和分区
除非您的 Kafka 集群配置为自动创建主题,否则您需要提前创建它。您可以参考 Kafka 快速入门文档 了解如何操作。