kafka 在 zookeeper 中保存的数据内容

转载请注明出处:

  1. 服务器上下载 kafka :
wget https://archive.apache.org/dist/kafka/2.4.0/kafka_2.12-3.2.0.tgz
  1. 解压之后,启动kafka内置的zookeeper 和 kafka 服务
启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka
bin/kafka-server-start.sh -daemon config/server.properties
  1. 创建队列 test_topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_topic
  1. 连接kafka内置的zookeeper 的客户端
bin/zookeeper-shell.sh localhost:2181
  1. 在zookeeper 的客户端中通过 ls 查看所有的节点数据:

kafka 在 zookeeper 中保存的数据内容

各节点的意义:

  • admin: 存储管理员接口操作的相关信息,主要为 topic 删除事件,分区迁移事件,优先副本选举,信息 (一般为临时节点)
  • brokers: 主要存储 broker 相关的信息,broker 节点以及节点上的 topic 相关信息
  • cluster: 存储 kafka 集群信息
  • config: 存储 broker,client,topic,user 以及 changer 相关的配置信息
  • consumers: 存放消费者相关信息 (一般为空)
  • controller: 用于存放控制节点信息 (注意:该节点是一个临时节点,用于 controller 节点注册)
  • controller_epoch: 用于存放 controller 节点当前的年龄
  • isr_change_notification: 用于存储 isr 的变更通知 (临时节点,当有 isr 进行变动时,会用于事件通知,可进行 watch 获取集群 isr 状态变更)
  • latest_producer_id_block: 该节点用于存储处理事务相关的 pid 范围
  • log_dir_event_notification: 日志目录事件通知

kafka 在 zookeeper 中保存的数据内容

Original: https://www.cnblogs.com/zjdxr-up/p/16496303.html
Author: 香吧香
Title: kafka 在 zookeeper 中保存的数据内容

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/611658/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

  • 演示webuploader和cropperjs图片裁剪上传

    最近有个项目要在浏览器端裁剪并上传图片。由于缺乏人力,只能我上阵杀敌。通过参考各种文章,最后决定用cropperjs进行图片裁剪,用webuploader上传文件。本文涉及到的知识…

    Linux 2023年6月6日
    0105
  • 【滚动更新】C++ 八股文选集(没代码,纯应试)

    1,变量的声明和定义有什么区别。 声明不分配内存,定义分配内存。变量只能被定义一次,但可以被声明多次。 2,#ifdef、#else、#endif和#ifndef的作用。 预处理条…

    Linux 2023年6月13日
    096
  • Scipy

    1.Scipy简介 使用python做科学计算,详情参考官方文档 scipy软件包包含专用于科学计算中常见问题的各种工具箱,他的不同子模块对应于不同的应用程序,例如插值,积分,优化…

    Linux 2023年6月6日
    083
  • 高等代数:1 线性方程组的解法

    1 线性方程组的解法 1、线性方程组:左端为未知量x的一次齐次式,右端是常数。关键词:系数、常数项、n元线性方程组、解集 2、线性方程组的初等变换:1)把一个方程的倍数加到另一个方…

    Linux 2023年6月8日
    0106
  • 模糊测试基本概念FuzzTest

    1. what is FUZZ TESTing? Fuzz Testing is an automated software testing technology, origina…

    Linux 2023年6月7日
    076
  • 数据库备份数据脚本

    #!/bin/bash currentpath=dirname $0 if [ ${currentpath} == ‘.’ ];then currentpath=pwd fi ba…

    Linux 2023年6月8日
    080
  • Docker常用命令

    Docker常用命令 删除安装包: sudo apt-get purge docker-ce 删除镜像、容器、配置文件等内容:…

    Linux 2023年6月6日
    0158
  • alloc_pages的实现浅析

    alloc_pages的使用 struct page *alloc_pages(gft_t gfp, unsigned int order) alloc_pages定义于 inux…

    Linux 2023年6月7日
    0107
  • 使用7z程序CLI实现基础功能

    阅文时长 | 0.64分钟字数统计 | 1025.6字符主要内容 | 1、引言&背景 2、压缩 3、解压 4、更多命令可见 5、声明与参考资料『使用7z程序CLI实现基础功…

    Linux 2023年6月14日
    095
  • Redis缓存查询时报字段无法识别问题-SerializationException: Could not read JSON: Unrecognized xxx

    报错信息: Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exce…

    Linux 2023年6月14日
    0101
  • .net core3.1 abp动态菜单和动态权限(思路) (二)

    ps:本文需要先把abp的源码下载一份来下,跟着一起找实现,更容易懂 在abp中,对于权限和菜单使用静态来管理,菜单的加载是在登陆页面的地方(具体是怎么知道的,浏览器按F12,然后…

    Linux 2023年6月7日
    0130
  • nodejs 环境安装

    Linux 系统安装 nodejs 环境 (root) 找到 nodejs 官网 http:…

    Linux 2023年6月14日
    0139
  • 《卡死你3000》批量修改被控机密码,秘钥

    批量生成密码之产生随机数: 默认产生16位大小写加数字密码 批量生成密码,并写入nodelist.csv: cs产生所有被控机旧密码并写入nodelist.ps1 运行这个脚本后,…

    Linux 2023年6月13日
    071
  • PicGo图床设置

    PicGo图床设置 介绍 PicGo是一款开源的图床管理工具,是可以快速的上传图片并且获得图片的URL链接的工具。目前支持Windows和macOS平台,可以方便的进行拖拽、复制粘…

    Linux 2023年6月6日
    0120
  • Timeout connecting to [localhost/127.0.0.1:9200]

    空服务启动时(或者压根没引入es相关jar包)报Timeout connecting to [localhost/127.0.0.1:9200]错误时,查看pom.xml中是否引用…

    Linux 2023年6月7日
    0141
  • 全域安全:一种运行时安全管理模型

    前言: 全域安全是一种新的安全管理模型,现在用在Laxcus分布式操作系统上,如果能够在ICT领域全面推广,当下计算机的安全问题,包括西工大的泄密事件,都可以避免了。以下是相关介绍…

    Linux 2023年6月6日
    098
亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球