当前位置: 首页 > news >正文

【Linux】Prometheus 监控 Kafka 集群

一、项目概述

kafka_exporter 是用于 Prometheus 的 Kafka 监控指标导出器,可帮助监控 Kafka 集群的各项指标。项目地址为:https://github.com/danielqsj/kafka_exporter

二、环境准备
  • 确保已安装 Prometheus生态环境,准备好kafka集群
三、下载与解压

可从 Releases 页面下载二进制文件,然后执行以下命令:

cd /opt
# 下载 kafka_exporter-1.9.0.linux-amd64.tar.gz 到当前目录
tar -zxvf kafka_exporter-1.9.0.linux-amd64.tar.gz
mv kafka_exporter-1.9.0.linux-amd64 kafka_exporter
cd kafka_exporter/
四、运行

运行 kafka_exporter 并指定 Kafka 服务器地址:

./kafka_exporter --kafka.server=kafka01:9092 --kafka.server=kafka02:9092 --kafka.server=kafka03:9092 --web.listen-address=:9308
  • 参数说明
    • --kafka.server:指定 Kafka 服务器的地址和端口,可以指定多个 Kafka 服务器。
    • --web.listen-address:指定 kafka_exporter 监听的地址和端口,这里监听在 9308 端口。
五、启动脚本示例

为了方便管理,可以创建一个启动脚本 start_export.sh

#!/bin/bash
./kafka_exporter \--kafka.server=kafka01:9092 \--kafka.server=kafka02:9092 \--kafka.server=kafka03:9092 \--web.listen-address=:9308 &

给脚本添加执行权限并运行:

chmod +x start_export.sh
./start_export.sh

Prometheus.yml添加export地址:

scrape_configs:- job_name: 'kafka'static_configs:- targets: ['192.168.100.150:9308']scrape_interval: 10s
六、可用标志
标志名称默认值描述
kafka.serverkafka:9092Kafka 服务器的地址(主机:端口)
kafka.version3.6.1Kafka 代理的版本
sasl.enabledfalse是否使用 SASL/PLAIN 进行连接
sasl.handshaketrue仅在使用非 Kafka SASL 代理时将此设置为 false
sasl.usernameSASL 用户名
sasl.passwordSASL 用户密码
sasl.mechanismplainSASL SCRAM SHA 算法:sha256 或 sha512,或者 SASL 机制:gssapi 或 awsiam
sasl.aws - regionAWS_REGION 环境变量IAM SASL 认证使用的 AWS 区域
sasl.service - name使用 Kerberos 认证时的服务名称
sasl.kerberos - config - pathKerberos 配置文件的路径
七、Grafana 仪表盘
  1. 登录 Grafana 控制台。
  2. 点击左侧菜单的 “+” 号,选择 “Import”。
  3. 导入grafna_id号21078 对应 KAFKA Dashboard CN 20240520 StarsL.cn
  4. 配置数据源等信息,完成仪表盘导入。
    在这里插入图片描述
http://www.dtcms.com/a/290005.html

相关文章:

  • Spring MVC 核心工作流程
  • 车载电子电器架构 --- MCU信息安全相关措施
  • docker 软件bug 误导他人 笔记
  • JSX(JavaScript XML)‌简介
  • 力扣15:三数之和
  • 【洛谷】The Blocks Problem、合并两个有序数组,补充pair(vector相关算法题p2)
  • 闲庭信步使用图像验证平台加速FPGA的开发:第二十八课——图像膨胀的FPGA实现
  • “融合进化,智领未来”电科金仓引领数字化转型新纪元
  • Flutter和Kotlin的对比
  • 【用unity实现100个游戏之34】使用环状(车轮)碰撞器(Wheel Collider)从零实现一个汽车车辆物理控制系统,实现一个赛车游戏
  • kotlin和Jetpack Compose对于Android系统来说是什么关系?
  • Python 进阶(七):XML 基本操作
  • opencv无法读取视频
  • Python100个库分享第38个—lxml(爬虫篇)
  • Navicat 17.3 正式发布 | 现已支持达梦、金仓和 IvorySQL 数据库
  • 图片转 PDF三个免费方法总结
  • C++ - 仿 RabbitMQ 实现消息队列--服务端核心模块实现(二)
  • CoolUtils Total PDF Converter:多功能PDF转换专家
  • STM32之GPS定位模块(GT-U8)
  • 合并pdf工具下载
  • Kotlin 高阶函数初步学习
  • k8s的calico无法启动报错解决
  • 集群技术笔记-HAProxy 与 Keepalived 高可用负载均衡实战
  • 如何使用python网络爬虫批量获取公共资源数据实践技术应用
  • 江苏思必驰科技25Java实习面经
  • 杰和科技工业计算机AF208,打造高可靠新能源汽车检测产线
  • Valgrind Cachegrind 全解析:用缓存效率,换系统流畅!
  • 基于springboot+vue+mysql的在线教育系统(源码+论文)
  • 多级缓存(亿级流量缓存)
  • 布局AI +文化新赛道,浙江省文化产业投资集团赴景联文科技调研交流