文档文档

Burrow 输入插件

此插件通过 HTTP APIBurrow - Kafka Consumer Lag Checking 伴侣收集 Kafka 主题、消费者和分区状态。支持 Burrow v1.x 版本。

引入于: Telegraf v1.7.0 标签: messaging 操作系统支持: all

全局配置选项

插件支持其他全局和插件配置设置,用于修改指标、标签和字段,创建别名以及配置插件顺序等任务。更多详情请参阅 CONFIGURATION.md

配置

# Collect Kafka topics and consumers status from Burrow HTTP API.
[[inputs.burrow]]
  ## Burrow API endpoints in format "schema://host:port".
  ## Default is "https://:8000".
  servers = ["https://:8000"]

  ## Override Burrow API prefix.
  ## Useful when Burrow is behind reverse-proxy.
  # api_prefix = "/v3/kafka"

  ## Maximum time to receive response.
  # response_timeout = "5s"

  ## Limit per-server concurrent connections.
  ## Useful in case of large number of topics or consumer groups.
  # concurrent_connections = 20

  ## Filter clusters, default is no filtering.
  ## Values can be specified as glob patterns.
  # clusters_include = []
  # clusters_exclude = []

  ## Filter consumer groups, default is no filtering.
  ## Values can be specified as glob patterns.
  # groups_include = []
  # groups_exclude = []

  ## Filter topics, default is no filtering.
  ## Values can be specified as glob patterns.
  # topics_include = []
  # topics_exclude = []

  ## Credentials for basic HTTP authentication.
  # username = ""
  # password = ""

  ## Optional SSL config
  # ssl_ca = "/etc/telegraf/ca.pem"
  # ssl_cert = "/etc/telegraf/cert.pem"
  # ssl_key = "/etc/telegraf/key.pem"
  # insecure_skip_verify = false

分组/分区状态映射

  • OK = 1
  • NOT_FOUND = 2
  • WARN = 3
  • ERR = 4
  • STOP = 5
  • STALL = 6

未知值将被映射到 0

Metrics

字段

  • burrow_group (每个消费者分组一个事件)

    • status (字符串, 请参阅分区状态映射)
    • status_code (整数, 1..6, 请参阅分区状态映射)
    • partition_count (整数, 分区数)
    • offset (int64, 所有分区的总偏移量)
    • total_lag (int64, 总延迟)
    • lag (int64, maxlag.current_lag || 0)
    • timestamp (int64, end.timestamp)
  • burrow_partition (每个主题分区一个事件)

    • status (字符串, 请参阅分区状态映射)
    • status_code (整数, 1..6, 请参阅分区状态映射)
    • lag (int64, current_lag || 0)
    • offset (int64, end.timestamp)
    • timestamp (int64, end.timestamp)
  • burrow_topic (每个主题偏移量一个事件)

    • offset (int64)

标签

  • burrow_group

    • cluster (字符串)
    • group (字符串)
  • burrow_partition

    • cluster (字符串)
    • group (字符串)
    • topic (字符串)
    • partition (整数)
    • owner (字符串)
  • burrow_topic

    • cluster (字符串)
    • topic (字符串)
    • partition (整数)

示例输出


此页面是否有帮助?

感谢您的反馈!


InfluxDB 3.8 新特性

InfluxDB 3.8 和 InfluxDB 3 Explorer 1.6 的主要增强功能。

查看博客文章

InfluxDB 3.8 现已适用于 Core 和 Enterprise 版本,同时发布了 InfluxDB 3 Explorer UI 的 1.6 版本。本次发布着重于操作成熟度,以及如何更轻松地部署、管理和可靠地运行 InfluxDB。

更多信息,请查看

InfluxDB Docker 的 latest 标签将指向 InfluxDB 3 Core

在 **2026 年 2 月 3 日**,InfluxDB Docker 镜像的 latest 标签将指向 InfluxDB 3 Core。为避免意外升级,请在您的 Docker 部署中使用特定的版本标签。

如果使用 Docker 来安装和运行 InfluxDB,latest 标签将指向 InfluxDB 3 Core。为避免意外升级,请在您的 Docker 部署中使用特定的版本标签。例如,如果使用 Docker 运行 InfluxDB v2,请将 latest 版本标签替换为 Docker pull 命令中的特定版本标签 — 例如

docker pull influxdb:2