kafka 消息模型、线程模型

connection1

send-q

网卡

响应

response

1

ACK = 0 时 发送一次 不论leader是否接收ACK = 1 时，等待leader接收成功即可ACK = -1 时 ，需等待leader将消息同步给follower

broker 3

topic

1、AR（Assigned Repllicas）一个partition的所有副本（就是replica，不区分leader或follower）2、ISR（In-Sync Replicas）能够和 leader 保持同步的 follower + leader本身 组成的集合。3、OSR（Out-Sync Relipcas）不能和 leader 保持同步的 follower 集合4、公式：AR = ISR + OSR

响应队列1

partation-0（leader）

消息队列

partation-0(follower)

连接器1

response

producter1

request

partation-1（leader）

broker

partation-1(follower)

producter2

处理线程

broker 1

……

KafkaIO模型

broker 2

2

连接器

连接器2

listenter accept()

响应队列2