0
点赞
收藏
分享

微信扫一扫

Kafka图解


 

Kafka图解_保存数据

 

 

 

Kafka图解_公众号_02

 

Kafka图解_数据_03

 

 

 

 

 

 

 

 类似于公众号订阅

 

缺点;消费者主动拉取的模式中,消费者主动轮询队列有没有消息

Kafka图解_公众号_04

 

 

 

 

Kafka图解_公众号_05

 

 

Kafka图解_数据_06

 

 

Kafka图解_保存数据_07

Kafka图解_公众号_08

 

 

 

 

Kafka图解_公众号_09

 

 

 

Kafka图解_保存数据_10

 

Kafka图解_数据_11

 

 

Kafka图解_保存数据_12

 

 

 

 

 

 

1:同一个组的消费者,不能消费同一个分区的数据

例如consumer A 和 consume B 是同一个组的,他们两不能消费Partition 0 的数据

2:读写数据之能从Leader上,Follow只能做备份

Kafka图解_保存数据_13

 

 

 

Kafka图解_保存数据_14

 

Kafka图解_数据_15

 

Kafka图解_保存数据_16

 

Kafka图解_公众号_17

 

 

Kafka图解_数据_18

Kafka图解_保存数据_19

 

 

Kafka图解_公众号_20

 

 

 

 

 

Kafka图解_数据_21

 

 

Kafka图解_公众号_22

 

 

 

 

 

 

 

ack机制

所有的followers都备份完了,都写入成功了

followers给leader法施工ack应答

然后leader会给producer

 

Kafka图解_数据_23

 

 

 

 

 

 

Kafka图解_保存数据_24

 

 

Kafka图解_公众号_25

Kafka图解_数据_26

 

Kafka图解_公众号_27

 

 

 

 

 

.log文件是保存数据的

.index是保存offset位置的

Kafka图解_保存数据_28

 

 

 

 

 

Kafka图解_保存数据_29

Kafka图解_公众号_30


 

 

 

 

 

Kafka图解_公众号_31

Kafka图解_公众号_32

 

 

 

 

Kafka图解_数据_33

 

 

 

Kafka图解_数据_34

 

 

 

Kafka图解_保存数据_35

 

 

 

举报

相关推荐

0 条评论