插件 〉Kafka


开发者

Hamed Karbasi

注册以接收不定期的产品新闻和更新



数据源
社区

Kafka

  • 概览
  • 安装
  • 更新日志
  • 相关内容

适用于 Grafana 的 Kafka 数据源

License CI Release

Kafka 数据源插件允许您在 Grafana 中可视化流式 Kafka 数据。

要求

  • Apache Kafka v0.9+
  • Grafana v8.0+

注意:这是一个后端插件,因此 Grafana 服务器应能访问 Kafka Broker。

入门

通过 grafana-cli 工具安装

使用 grafana-cli 工具从命令行安装插件

grafana-cli plugins install hamedkarbasi93-kafka-datasource

插件将安装到您的 Grafana 插件目录中;默认路径为 /var/lib/grafana/plugins有关 cli 工具的更多信息

通过 zip 文件安装

或者,您可以手动下载最新的发布版 .zip 文件并将其解压到您的 Grafana 插件目录中;默认路径为 /var/lib/grafana/plugins

配置数据源

添加数据源,填写以下字段:

基本字段

字段描述
名称此特定 AppDynamics 数据源的名称
服务器Kafka Bootstrap 服务器的 URL,用逗号分隔。例如:broker1:9092, broker2:9092

查询数据源

要查询 Kafka Topic,您需要在查询编辑器中配置以下项。

字段描述
TopicTopic 名称
分区分区编号
自动重置 Offset开始消费的 Offset,可以是最新的或最后 100 个。
时间戳模式要可视化消息值的时间戳;可以是“当前时间”或“消息时间戳”

注意:请确保启用 streaming 开关。

kafka dashboard

已知限制

  • 当前插件不支持任何授权和身份验证方法。
  • 当前插件不支持 TLS。
  • 插件基于 confluent-kafka-go,因此它目前只支持基于 Linux 的操作系统,如 #6 中讨论的。然而,我们正在考虑更改基础包以支持所有操作系统。

该插件支持发布非常简单的 JSON 格式消息的 Topic。请注意,目前仅支持以下结构:

{
    "value1": 1.0,
    "value2": 2,
    "value3": 3.33,
    ...
}

我们计划在后续版本中支持更复杂的 JSON 数据结构、Protobuf 和 AVRO。非常欢迎贡献!

自行编译数据源

数据源后端插件由前端和后端组件组成。

前端

  1. 安装依赖项

    yarn install
    
  2. 在开发模式下构建插件或以监视模式运行

    yarn dev
    

    yarn watch
    
  3. 在生产模式下构建插件

    yarn build
    

后端

  1. Grafana plugin SDK for Go 依赖项更新到最新的次要版本

    go get -u github.com/grafana/grafana-plugin-sdk-go
    go mod tidy
    
  2. 为 Linux 构建后端插件二进制文件

    mage build:backend
    

贡献

感谢您考虑贡献!如果您发现问题或有更好的实现方式,请随时提交 issue 或 PR。

许可证

本仓库是根据 Apache 许可证 2.0 授权的开源软件。

了解更多

在 Grafana Cloud 上安装 Kafka

欲了解更多信息,请访问插件安装文档。

更新日志

1.0.0(未发布)

初次发布。