首页 > 其他分享 >kafka-03-主题分区副本

kafka-03-主题分区副本

时间:2022-09-20 03:55:12浏览次数:69  
标签:03 副本 -- 创建 分区 kafka topic

搭建一个主题,两个分区,三个副本环境

搭建一个主题:
1.创建topic 
exec -it 先进入kafka容器,然后在/opt/kafka/bin 目录下执行命令:
用kafka 的bin目录下的脚本:(往192.168.56.128:2181这个zk上创建)
./kafka-topics.sh --create --zookeeper 192.168.56.128:2181 --replication-factor 3 --partitions 2 --topic wyw-replication

创建了一个名字叫做 wyw-replication topic 这里用的是zk的地址,也就是创建kafka的topic ,是向zk创建一个主题。

2.查看zk中的所有主题:
./kafka-topics.sh --list --zookeeper 192.168.56.128:2181 

image

image

查看topic 信息:
./kafka-topics.sh --describe  --zookeeper 192.168.56.128:2181  --topic wyw-replication

image

创建的topic 是再zk上创建的,docker ps看一下 ,目前有三个kafka,也就是三个broker启动着:

image

创建topic的时候没事不关心进入哪个kafka,是都可以创建的。

image

生产消息和消费消息,都在是leader 的副本上, 不会在其他副本上,其他副本在 leader 挂了的时候起作用。

Replicas:2,0,1 -----意思是broker节点关系。数字都是broker 的id

Isr:2,0,1-------------内容包括:可以同步的broker节点,已同步的broker节点。(性能较差,就会被干掉)

副本的概念:其实就是对主题中的分区做备份,一个副本作为leader,其他作为follower

读写都在leader 上!!!

follower 接收同步的数据

分区之前说了,是物理的存储,把消息存储到不同的分区中。

进入kafka节点容器,进入/kafka 目录下,查看文件结构

image

进入kafka2节点容器,进入/kafka 目录下,查看文件结构

image

可以看到有两个分区的副本。

标签:03,副本,--,创建,分区,kafka,topic
From: https://www.cnblogs.com/wyw123456/p/16709728.html

相关文章

  • 代码03
    print("今有物不知其数,三三数之剩二,五五数之剩三,七七数之剩二,问几何?\n")number=int(input("请输入您认为符合条件的数:"))ifnumber%3==2andnumber%5==3andnumber%7==......
  • You're accessing the development server over HTTPS, but it only supports HTTP.报
    1.安装https支持包pip3installdjango-extensionspip3installdjango-werkzeug-debugger-runserverpip3installpyOpenSSL2.在settings中添加INSTALLED_APPS......
  • Java基础03——方法
    方法的定义与调用方法的定义类似函数,用于完成特定功能的代码片段格式:修饰符返回值类型方法名(参数类型参数名){​ 方法体;​ return返回值;}参数类型:实参(实......
  • kafka相关命令
    1,创建Topic2,往Topic写入数据命令:kafka-producer-perf-test--topicck_test111--num-records1000--record-size2000--throughput1000--producer-propsbootstrap......
  • 项目代码在pycharm中可以正常运行,但是linux运行报错No module named 'XX'
    问题产生的原因:pycharm自动将代码的主函数路径加入到运行中去,但是linux不会。解决问题的本质:为项目中文件找到更目录并添加到sys路径中。项目实例   原始的项目......
  • 解决苹果钥匙串-34018错误: A required entitlement isn't present.
        最近破解了一个苹果版本关键软件,在跳过各种检测延长试用时间之后发现无法保存钥匙串数据了。调试后发现SecItemAdd无法添加钥匙串,返回值-34018,搜寻后发现是因......
  • 2022-09-19 Error: Cannot find module '项目\node_modules\@vue\cli-service\bin
    前言:wepy项目迁移uniapp使用wepy-to-uniapp转换代码后初始化依赖抛出的错误:Error:Cannotfindmodule'项目\node_modules\@vue\cli-service\bin\vue-cli-service.js'网......
  • T1003: 对齐输出(信息学一本通C++)
    [题目描述]读入三个整数,按每个整数占8个字符的宽度,右对齐输出它们,按照格式要求依次输出三个整数,之间以一个空格分开。[输入]只有一行,按照格式要求依次输出三个整数,之间......
  • JSR303数字校验
    天空和我的中间,只剩下倾盆的思念简单校验使用示例:引入对应的校验依赖<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring......
  • 剑指 Offer II 003. 前 n 个数字二进制中 1 的个数【模拟】
    题目给定一个非负整数n,请计算0到n之间的每个数字的二进制表示中1的个数,并输出一个数组。难度:简单说明:0<=n<=105题解按照题意模拟即可classSolutio......