搭建一个主题,两个分区,三个副本环境
搭建一个主题:
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
查看topic 信息:
./kafka-topics.sh --describe --zookeeper 192.168.56.128:2181 --topic wyw-replication
创建的topic 是再zk上创建的,docker ps看一下 ,目前有三个kafka,也就是三个broker启动着:
创建topic的时候没事不关心进入哪个kafka,是都可以创建的。
生产消息和消费消息,都在是leader 的副本上, 不会在其他副本上,其他副本在 leader 挂了的时候起作用。
Replicas:2,0,1 -----意思是broker节点关系。数字都是broker 的id
Isr:2,0,1-------------内容包括:可以同步的broker节点,已同步的broker节点。(性能较差,就会被干掉)
副本的概念:其实就是对主题中的分区做备份,一个副本作为leader,其他作为follower
读写都在leader 上!!!
follower 接收同步的数据
分区之前说了,是物理的存储,把消息存储到不同的分区中。
进入kafka节点容器,进入/kafka 目录下,查看文件结构
进入kafka2节点容器,进入/kafka 目录下,查看文件结构
可以看到有两个分区的副本。
标签:03,副本,--,创建,分区,kafka,topic From: https://www.cnblogs.com/wyw123456/p/16709728.html