首页 > 其他分享 >Kafka在Zookeeper上的节点信息和查看方式

Kafka在Zookeeper上的节点信息和查看方式

时间:2022-12-30 16:02:41浏览次数:41  
标签:12 topics Zookeeper Kafka lockcar zookeeper brokers 节点

Kafka简介
Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协调的分布式消息系统,它的最大的特性就是可以实时的处理大量数据以满足各种需求场景:比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎,web/nginx日志、访问日志,消息服务等等,用scala语言编写,Linkedin于2010年贡献给了Apache基金会并成为顶级开源 项目。
Kafka启动:(根据自身路径更改)
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
Zookeeper启动:(根据自身路径更改)
/usr/local/zookeeper/bin/zkServer.sh start
进入客户端的命令:{zookeeper目录}/bin/zkCli.sh
/usr/local/zookeeper/bin/zkCli.sh
以下是几个zookeeper客户端用的命令,不只kafka,其他任何注册到zookeeper的服务都可以使用这些命令。
1、ls
ls会显示该节点下的子节点信息
比如:ls /
1. [zk: localhost:2181(CONNECTED)1] ls /
2. [dubbo, log_dir_event_notification, isr_change_notification, zookeeper, admin, consumers, cluster, config, latest_producer_id_block, controller, brokers, controller_epoch]
#显示zookeeper根目录下的子节点,其中kafka的broker在zookeeper根目录注册了brokers节点
比如:ls /brokers/topics/lockcar_loction/partitions
1. [zk: localhost:2181(CONNECTED)2] ls /brokers/topics/lockcar_loction/partitions
2. [1,0]
#显示lockcar_loction这个topic下的partitions的子节点
2、get
get命令会显示该节点的节点数据内容和属性信息
比如:get /brokers/topics/lockcar_loction
1. [zk: localhost:2181(CONNECTED)2]get/brokers/topics/lockcar_loction
2. {"version":1,"partitions":{"1":[1],"0":[3]}}
3. cZxid =0x5000000cf
4. ctime =WedApr0809:12:12 CST 2020
5. mZxid =0x5000000cf
6. mtime =WedApr0809:12:12 CST 2020
7. pZxid =0x5000000d2
8. cversion =1
9. dataVersion =0
10. aclVersion =0
11. ephemeralOwner =0x0
12. dataLength =44
13. numChildren =1
#显示lockcar_loction这个topic的节点数据内容和属性信息。
#第一行大括号里面就是节点的数据内容,创建topic时候的定义的topic级别配置会被记录在这里
3、ls2
ls2命令会显示该节点的子节点信息和属性信息
比如:ls2 /brokers/topics/lockcar_loction
1. [zk: localhost:2181(CONNECTED)4] ls2 /brokers/topics/lockcar_loction
2. [partitions]
3. cZxid =0x5000000cf
4. ctime =WedApr0809:12:12 CST 2020
5. mZxid =0x5000000cf
6. mtime =WedApr0809:12:12 CST 2020
7. pZxid =0x5000000d2
8. cversion =1
9. dataVersion =0
10. aclVersion =0
11. ephemeralOwner =0x0
12. dataLength =44
13. numChildren =1
#显示lockcar_loction这个topic的子节点和属性信息。
#第一行中括号里的是子节点。
• 输入编号:6692,直达文章
• 输入m|M,直达目录列表

标签:12,topics,Zookeeper,Kafka,lockcar,zookeeper,brokers,节点
From: https://blog.51cto.com/u_12018693/5980586

相关文章

  • Kafka Reblance & max.poll.interval.ms 重复消费问题
    1.什么是kafkaReblance    消费组是MQ中一个非常重要的概念,一个消费组监听一个Topic时,Kafka服务端会给消费组中的每一个实例,进行队列分配,每一个实例指定消费一个或......
  • Kafka的终极UI工具丨Offset Explorer功能简介
    OffsetExplorer(以前称为KafkaTool)是一个用于管理和使ApacheKafka®集群的GUI应用程序。它提供了一个直观的UI,允许人们快速查看Kafka集群中的对象以及存储在集群主题......
  • 【vsan数据恢复】vsan集群节点磁盘离线,数据重构失败导致vsan分布式存储瘫痪的数据恢复
    vsan数据恢复环境:一组4台服务器搭建vsan集群;每台服务器配置有2组分别由6块硬盘组成的磁盘阵列,上层是虚拟机文件。vsan故障:在运行过程中,某一个节点的一块硬盘离线,vsan安......
  • zookeeper集群搭建中服务启动常见问题
    1、执行./zkServer.shstart后查看服务状态显示Itisprpbably isnotrunning.但是查看进程jps,zookeeper服务进程是正常启动的。解决办法:先停止zookeeper服务./zkServer.......
  • 模拟spring-kafka实现kafka的consumer监听
    背景:因为某些原因,无法直接使用springboot提供的@KafkaListener,改为模拟springboot注解的方式搬过来实现首先创建一个业务处理的service,这个service主要用于消费下来的消息......
  • 使用jQuery操作节点
    DOM的分类:DOMcore指所有支持DOM的功能都可以进行使用操作HTMLDOM网页中的所有标签或节点CSSDOM指网页中的优化样式在控制台输出信息:console.log("元素的......
  • kubernetes的node节点无法部署pod
    尝试了网上的方法,都没有用,最后能重启机器和重启kubectl解决了报错:Failedtocreatepodsandbox:rpcerror:code=Unknowndesc=[failedtosetupsandboxcontain......
  • BM9 删除链表的倒数第n个节点
    题目描述牛客原题代码参考//可以借助之前,追击的问题,借助返回倒数第k个节点的题的基础上functionremoveNthFromEnd(head,n){//writecodelet......
  • Zookeeper的应用场景
    1、数据发布与订阅(配置中心)数据发布/订阅系统,即配置中心。需要发布者将数据发布到Zookeeper的节点上,供订阅者进行数据订阅,进而达到动态获取数据的目的,实现配置信息的集中式......
  • Kafka集群升级实施方案
    一、背景我们组内维护的kafka集群承担着公司绝大部分实时数据的收集传输任务。但是,现阶段存在如下问题,已经对集群的稳定性、用户的使用以及管理员的运维造成了很大影响:1......