Kafka实战
01、Kafka：为什么要使用消息队列
02、Kafka：消息队列的流派
03、Kafka：安装Kafka服务器
04、Kafka：实现生产者和消费者
05、Kafka：消息的偏移量和顺序消费原理
06、Kafka：单播和多播消息的实现
07、Kafka：主题和分区的概念
08、Kafka：搭建Kafka集群
09、Kafka：副本的概念
10、Kafka：集群消费问题
11、Kafka：Java中Kafka生产者的基本实现
12、Kafka：生产者端的同步发送和异步发送
13、Kafka：生产者中的ack配置
14、Kafka：发送消息的缓冲区机制
15、Kafka：消费者消费消息的基本实现
16、Kafka：Offset的自动提交和手动提交
17、Kafka：消费者poll消息的细节与消费者心跳配置
18、Kafka：指定分区和偏移量，时间消费
19、Kafka：新消费组的消费offset规则
20、Kafka：SpringBoot中使用Kafka的基本实现
21、Kafka：消费者的配置细节
22、Kafka：Kafka中Controller，Rebalance，HW，LEO的概念
23、Kafka：Kafka优化之防止消息丢失和重复消费
24、Kafka：Kafka优化之顺序消费的实现
25、Kafka：Kafka优化之解决消息积压问题
26、Kafka：Kafka优化之实现延时队列
27、Kafka：Kafka-eagle监控平台
28、Kafka：Linux部署Kafka集群
29、Kafka：Docker-compose部署Kafka集群
本文档使用 MrDoc 发布
-
+
home page
09、Kafka：副本的概念
### **副本的概念** 在创建主题时，除了指明了主题的分区数以外，还指明了副本数，那么副本是⼀个什么概念呢？ 副本是对分区的备份。在集群中，不同的副本会被部署在不同的broker上。下⾯例⼦：创建1个主题，2个分区、3个副本。 ```python ./kafka-topics.sh \ --create \ --zookeeper 172.16.253.35:2181 \ --replication-factor 3 \ --partitions 2 \ --topic my-replicated-topic ``` 副本是为了为主题中的分区创建多个备份，多个副本在kafka集群的多个broker中，会有⼀个副本作为leader，其他是follower。 查看topic情况: ```python # 查看topic情况 ./kafka-topics.sh \ --describe \ --zookeeper 172.16.253.35:2181 \ --topic my-replicated-topic ```  - leader： kafka的写和读的操作，都发⽣在leader上。leader负责把数据同步给follower。当leader挂了，经过主从选举，从多个follower中选举产⽣⼀个新的leader - follower 接收leader的同步的数据 - isr： 可以同步和已同步的节点会被存⼊到isr集合中。这⾥有⼀个细节：如果isr中的节点性能较差，会被提出isr集合。 ### **（重点～！）** 此时，broker、主题、分区、副本 这些概念就全部展现了，⼤家需要把这些概念梳理清楚： 集群中有多个broker，创建主题时可以指明主题有多个分区（把消息拆分到不同的分区中存储），可以为分区创建多个副本，不同的副本存放在不同的broker⾥。
李智
March 17, 2025, 1:29 p.m.
转发文档
Collection documents
Last
Next
手机扫码
Copy link
手机扫一扫转发分享
Copy link
Markdown文件
share
link
type
password
Update password