搜索

15.3. 为 MirrorMaker 和 Kafka Connect 设置追踪

download PDF

本节论述了如何配置 MirrorMaker、MirrorMaker 2.0 和 Kafka Connect 以实现分布式追踪。

您必须为每个组件启用 Jaeger tracer。

15.3.1. 为 MirrorMaker 启用追踪

通过将 Interceptor 属性作为消费者和制作者配置参数传递,为 MirrorMaker 启用分布式追踪。

信息从源集群跟踪到目标集群。跟踪数据记录进入和离开 MirrorMaker 组件的信息。

流程

  1. 配置并启用 Jaeger tracer。
  2. 编辑 /opt/kafka/config/consumer.properties 文件。

    添加以下 Interceptor 属性:

    consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor
  3. 编辑 /opt/kafka/config/producer.properties 文件。

    添加以下 Interceptor 属性:

    producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
  4. 使用使用者和制作者配置文件作为参数启动 MirrorMaker:

    su - kafka
    /opt/kafka/bin/kafka-mirror-maker.sh --consumer.config /opt/kafka/config/consumer.properties --producer.config /opt/kafka/config/producer.properties --num.streams=2
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.