公司有多套 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 的监控相关推荐

  1. zookeeper模拟监控服务节点宕机

    2019独角兽企业重金招聘Python工程师标准>>> zookeeper模拟监控服务节点宕机 /*** 模拟监控服务节点宕机* 思路:* 节点上线的时候,往/watch下创建一个节 ...

  2. Apache ZooKeeper - JMX监控 ZooKeeper 的运行状态

    文章目录 Pre JMX配置 OP 开启 JMX JConsle 通过 JMX访问远端 ZooKeeper服务 Pre 为了应用服务能够持续稳定地对外提供服务,除了在部署的时候尽量采用分布式.集群服务 ...

  3. 使用Zabbix监控ZooKeeper服务的健康状态

    一 应用场景描述 在目前公司的业务中,没有太多使用ZooKeeper作为协同服务的场景.但是我们将使用Codis作为Redis的集群部署方案,Codis依赖ZooKeeper来存储配置信息.所以做好Z ...

  4. 一文运维zookeeper

    文章目录 1. zookeeper生产环境的安装配置 1.1 软件配置 1.2 硬件配置 1.3 日志配置文件 1.4 配置三节点的zookeeper集群 2. zookeeper的监控方法 2.1 ...

  5. 一文入门 Zookeeper

    文章目录 1. zookeeper 简介 1.1 什么是zookeeper 1.2 zookeeper 发展历史 1.3 zookeeper 典型应用场景 1.4 zookeeper 提供的服务 1. ...

  6. Zookeeper的java实例

    还是在之前的模块中写这个例子: 注意在pom.xml中加上Zookeeper的依赖, 现在开始写ZookeeperDemo.java import org.apache.log4j.Logger; i ...

  7. Zookeeper原生客户端

    1.1.1.1. 客户端基本操作 package cn.enjoy.javaapi; import org.apache.zookeeper.*; import java.io.IOException ...

  8. sql 树状结构中知道 父节点与孙节点_集群环境中使用Zookeeper实现分布式幂等控制...

    一.什么是Zookeeper? Zookeeper(业界简称zk)是一种提供配置管理.分布式协同以及命名的中心化服务,这些提供的功能都是分布式系统中非常底层且必不可少的基本功能,但是如果自己实现这些功 ...

  9. zookeeper源码分析之一服务端启动过程

    zookeeper简介 zookeeper是为分布式应用提供分布式协作服务的开源软件.它提供了一组简单的原子操作,分布式应用可以基于这些原子操作来实现更高层次的同步服务,配置维护,组管理和命名.zoo ...

  10. Apache ZooKeeper - FourLetterCommands运维命令

    文章目录 Pre 安装nc 常见的四字母命令 FourLetterCommands 命令解析 confs cons stat mntr srvr ruok Question Pre Apache Zo ...

最新文章

  1. Dockefile CentOS SSH 服务的实现
  2. 跨境电商自建站后台系统原型rp_Shoptago---跨境电商平台又一个新选择
  3. nginx 下配置使用Thinkphp5解决跨目录活动并且设置网站根目录
  4. Mybatis的mapper标签 namespace属性说明
  5. 修复版ZFAKA发卡系统源码 自适应PC+手机端
  6. 屏蔽预训练模型的权重。 只训练最后一层的全连接的权重。_轻量化 | 如何让笨重的深度学习模型在移动设备上跑起来?看它!...
  7. mapreduce阶段出现pending的原因及解决
  8. 你想要的宏基因组-微生物组知识全在这(2022.2)
  9. Java移位运算符详解实例
  10. Minecraft Mod开发:1-配置工作环境
  11. 串口通信协议【I2C、SPI、UART、RS232、RS422、RS485、CAN、TTL、USB】
  12. 视频分割合并软件哪个好用:试试Fast Video Cutter Joiner吧
  13. Solr高级查询Facet
  14. 卡贴机变无锁教程_有锁机变无锁教程 教你轻松设置去掉卡贴有锁机变无锁完美4G...
  15. python生成随机字符串和数字
  16. html鼠标悬浮更换图片,Vue.js鼠标悬浮更换图片功能
  17. 关于字符串中length与length()的区别
  18. 美联航客机门被冻坏无法起飞 乘客困机上约16小时
  19. Python之数据爬取数据可视化
  20. android手机华为p10,谁是运行速度最快的安卓手机?华为P10

热门文章

  1. 使用mimics重建CT图像
  2. mimics中三维构造,建立MASK
  3. Postman汉化中文版
  4. r语言与数据挖掘最佳实践和经典案例数据_R语言与数据挖掘最佳实践和经典案例...
  5. python求圆周率马青公式_计算圆周率的马青公式
  6. J-LINK驱动下载
  7. python opencv导入pbtxt文件出现错误Failed to parse GraphDef file
  8. RS232 RS422 RS485 DB9公座脚定义
  9. 微信公众号后台开发---永久素材失效
  10. Hutool使用总结(VIP典藏版)