简介
prometheus-kafka-connect 是一个 npm 包，它可以让你将 Kafka 的监控数据发送到 Prometheus 服务器，以方便地显示与分析。
安装
在项目中使用 npm 进行安装，命令如下：
npm install prometheus-kafka-connect
使用方法
引入
在代码中使用以下语句引入 prometheus-kafka-connect 包：
const PromKafkaConnect = require('prometheus-kafka-connect');初始化
初始化 PromKafkaConnect 实例时需要传入一些配置参数，例如：
-- -------------------- ---- -------
----- ------------- - --- ------------------
------------- ------------------------- -- -----------------
------ ------------------
------------ --------
-------- -
-
----- -------------------------
----- ----------
----------- --------- -------------
------------ ---- ------ -- -------- -------- --- --------
--
-
----- ---------------------
----- --------
----------- --------- -------------
------------ ---- ------- ---- -- --------- ------ --- --------- ------- ---- --- -----------
--
-
---配置参数说明：
kafkaBrokers: Kafka 集群的地址，多个地址用逗号分隔。默认值为localhost:9092。topic: Kafka 消费者将要消费的主题。groupingKey: Prometheus 开放指标 (expvar) 扩展的分组关键字 (grouping key)，默认值为'topic'。metrics: Prometheus 要发布的指标。
注册消费者
prom-kafka-connect 使用 Kafka Node.js 客户端库作为消费者进行消息消费，你可以通过如下代码注册 Kafka 消费者：
-- -------------------- ---- ------- ----- ----- - ---------------------- ----- ------------- - --- --------------------- ---------- ------------------------- -- ----------------- -------- ------------------- ----------- ------ -- --------------------- --------------------------- ----- --------- -- - -- - ----- ------ ------------- ---------- ----- -------------------------------------- --- ------------------------- ----- -- - -------------------- -------- -------- ----- ---
这个消费者会将 prometheus-test 主题上的消息取出来，打包放到 promKafkaConn 实例的队列中等待处理。
定期向 Prometheus 服务器推送指标
prometheus-kafka-connect 会定期将指标推送至 Prometheus 服务器，你可以通过如下代码来启动定时器：
promKafkaConn.startServer();
你还可以通过如下代码停止定时器：
promKafkaConn.stopServer();
示例代码
下面是一个完整的示例代码：
-- -------------------- ---- -------
----- ---------------- - ------------------------------------
----- ----- - ----------------------
----- ------------- - --- ------------------
------------- ------------------------- -- -----------------
------ ------------------
------------ --------
-------- -
-
----- -------------------------
----- ----------
----------- --------- -------------
------------ ---- ------ -- -------- -------- --- --------
--
-
----- ---------------------
----- --------
----------- --------- -------------
------------ ---- ------- ---- -- --------- ------ --- --------- ------- ---- --- -----------
--
-
---
-- -----
----- ------------- - --- ---------------------
---------- ------------------------- -- -----------------
-------- -------------------
----------- ------
-- ---------------------
--------------------------- ----- --------- -- -
-- - ----- ------ ------------- ----------
----- --------------------------------------
---
------------------------- ----- -- -
-------------------- -------- -------- -----
---
-- ------ ---------- -------
----------------------------结语
prometheus-kafka-connect 是一款非常方便的 npm 包，可以帮助我们将 Kafka 监控数据发送至 Prometheus 服务器，以对数据进行更好的管理与分析。希望这篇文章能对您有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600568ea81e8991b448e4a26