ZooKeeper 的监控
公司有多套 Kafka 集群,Kafka 依赖 ZooKeeper 提供分布式协调服务,研究一下关于 ZooKeeper 的监控指标查看。
Zookeeper 在 Kafka 中的应用
- Topic 配置管理: Topic 的配置会注册到 Zookeeper 中 的 config 节点下,根据 config 节点来动态更新配置;
- Broker 管理: 在每个 Broker 启动时,都会注册到 Zookeeper 的 brokers 节点下;
- Topic 及 Partition 管理: Topic 会注册到 brokers 节点下的 topics 节点下,Partition 会注册到 Topic 的节点下;
- Producer 负载均衡: Producer 将消息发布到 Topic 时,会根据 Zookeeper 的 brokers 节点下的 Broker 来进行动态的负载均衡;
- Consumer 负载均衡: Consumer 从 Topic 拉取消息时,同样也需要根据 Zookeeper 的 brokers 节点下的 Broker 来进行动态的负载均衡;
- 消费管理: 每个 Partition 只能被 Consumer Group 中的一个 Consumer 进行消费,因此需要关联 - Partition 与 Consumer 之间的关系,将 Consumer 的 Consumer ID 注册到相关联的 Partition 节点的临时节点上;
- Offset 记录: 在 Consumer 对指定 Partition 进行消息消费的过程中,需要将 Partition 的消费数量记录到 Zookeeper 中。
四字监控命令
# 输入
echo conf | nc localhost 2181 # 输出
clientPort=2181
secureClientPort=-1
# zk 用于保存内存数据库的快照的目录,除非设置了dataLogDir,否则这个目录也用来保存更新数据库的事务日志。
# 在生产环境使用的 zk 集群,强烈建议设置 dataLogDir,让 dataDir 只存放快照,
# 因为写快照的开销很低,这样 dataDir 就可以和其他日志目录的挂载点放在一起。
dataDir=/tmp/zookeeper/data/version-2
dataDirSize=0
# zk 的事务日志路径
dataLogDir=/tmp/zookeeper/datalog/version-2
dataLogSize=424
# 每个 tick 的毫秒数,每个确认消息持续 3 秒,等待应答。
tickTime=3000
maxClientCnxns=0
minSessionTimeout=6000
maxSessionTimeout=60000
serverId=0
- conf: 查询 Zookeeper 服务的配置信息。
- cons: 列出连接到 Zookeeper 服务的所有客户端的完整连接和会话详细信息。包括接收和发送的数据包数量、会话id、操作延迟、最后执行的操作等信息。
- crst: 重置服务端的连接和会话统计信息。
- dump: 适用于 Leader 节点,列出未完成的请求和临时节点。
- envi: 列出服务器的环境信息。
- ruok: 测试服务是否处于正确运行状态,如果正常返回 imok,否则返回空。
- srst: 重置服务的统计信息。
- srvr: 列出服务的详细信息。
- wchs: 列出服务的 Watcher 的简要信息。
- wchc: 按会话列出服务的 Watcher 的详细信息。
- wchp: 按路径列出服务带有 znode 列表的 Watcher 的详细信息。如果 Watcher 的数量多,会影响服务器性能,请谨慎使用。
- dirs: 以字节为单位显示快照和日志文件的总大小。
报错处理
conf is not executed because it is not in the whitelist.# 配置文件中添加
# 开启四字命令
4lw.commands.whitelist=*
ZooKeeper 的监控相关推荐
- zookeeper模拟监控服务节点宕机
2019独角兽企业重金招聘Python工程师标准>>> zookeeper模拟监控服务节点宕机 /*** 模拟监控服务节点宕机* 思路:* 节点上线的时候,往/watch下创建一个节 ...
- Apache ZooKeeper - JMX监控 ZooKeeper 的运行状态
文章目录 Pre JMX配置 OP 开启 JMX JConsle 通过 JMX访问远端 ZooKeeper服务 Pre 为了应用服务能够持续稳定地对外提供服务,除了在部署的时候尽量采用分布式.集群服务 ...
- 使用Zabbix监控ZooKeeper服务的健康状态
一 应用场景描述 在目前公司的业务中,没有太多使用ZooKeeper作为协同服务的场景.但是我们将使用Codis作为Redis的集群部署方案,Codis依赖ZooKeeper来存储配置信息.所以做好Z ...
- 一文运维zookeeper
文章目录 1. zookeeper生产环境的安装配置 1.1 软件配置 1.2 硬件配置 1.3 日志配置文件 1.4 配置三节点的zookeeper集群 2. zookeeper的监控方法 2.1 ...
- 一文入门 Zookeeper
文章目录 1. zookeeper 简介 1.1 什么是zookeeper 1.2 zookeeper 发展历史 1.3 zookeeper 典型应用场景 1.4 zookeeper 提供的服务 1. ...
- Zookeeper的java实例
还是在之前的模块中写这个例子: 注意在pom.xml中加上Zookeeper的依赖, 现在开始写ZookeeperDemo.java import org.apache.log4j.Logger; i ...
- Zookeeper原生客户端
1.1.1.1. 客户端基本操作 package cn.enjoy.javaapi; import org.apache.zookeeper.*; import java.io.IOException ...
- sql 树状结构中知道 父节点与孙节点_集群环境中使用Zookeeper实现分布式幂等控制...
一.什么是Zookeeper? Zookeeper(业界简称zk)是一种提供配置管理.分布式协同以及命名的中心化服务,这些提供的功能都是分布式系统中非常底层且必不可少的基本功能,但是如果自己实现这些功 ...
- zookeeper源码分析之一服务端启动过程
zookeeper简介 zookeeper是为分布式应用提供分布式协作服务的开源软件.它提供了一组简单的原子操作,分布式应用可以基于这些原子操作来实现更高层次的同步服务,配置维护,组管理和命名.zoo ...
- Apache ZooKeeper - FourLetterCommands运维命令
文章目录 Pre 安装nc 常见的四字母命令 FourLetterCommands 命令解析 confs cons stat mntr srvr ruok Question Pre Apache Zo ...
最新文章
- Dockefile CentOS SSH 服务的实现
- 跨境电商自建站后台系统原型rp_Shoptago---跨境电商平台又一个新选择
- nginx 下配置使用Thinkphp5解决跨目录活动并且设置网站根目录
- Mybatis的mapper标签 namespace属性说明
- 修复版ZFAKA发卡系统源码 自适应PC+手机端
- 屏蔽预训练模型的权重。 只训练最后一层的全连接的权重。_轻量化 | 如何让笨重的深度学习模型在移动设备上跑起来?看它!...
- mapreduce阶段出现pending的原因及解决
- 你想要的宏基因组-微生物组知识全在这(2022.2)
- Java移位运算符详解实例
- Minecraft Mod开发:1-配置工作环境
- 串口通信协议【I2C、SPI、UART、RS232、RS422、RS485、CAN、TTL、USB】
- 视频分割合并软件哪个好用:试试Fast Video Cutter Joiner吧
- Solr高级查询Facet
- 卡贴机变无锁教程_有锁机变无锁教程 教你轻松设置去掉卡贴有锁机变无锁完美4G...
- python生成随机字符串和数字
- html鼠标悬浮更换图片,Vue.js鼠标悬浮更换图片功能
- 关于字符串中length与length()的区别
- 美联航客机门被冻坏无法起飞 乘客困机上约16小时
- Python之数据爬取数据可视化
- android手机华为p10,谁是运行速度最快的安卓手机?华为P10