Skip to content

Commit d5c321b

Browse files
committed
docs(high-concurrency): update how-to-ensure-high-availability-of-message-queues.md
fix doocs#67, see https://github.com/doocs/advanced-java/blob/master/docs/high-concurrency/how-to-ensure-high-availability-of-message-queues.md
1 parent ce452ec commit d5c321b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

docs/high-concurrency/how-to-ensure-high-availability-of-message-queues.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ Kafka 0.8 以后,提供了 HA 机制,就是 replica(复制品) 副本机
5656

5757
![kafka-after](/images/kafka-after.png)
5858

59-
这么搞,就有所谓的**高可用性**了,因为如果某个 broker 宕机了,没事儿,那个 broker上面的 partition 在其他机器上都有副本的,如果这上面有某个 partition 的 leader,那么此时会从 follower 中**重新选举**一个新的 leader 出来,大家继续读写那个新的 leader 即可。这就有所谓的高可用性了。
59+
这么搞,就有所谓的**高可用性**了,因为如果某个 broker 宕机了,没事儿,那个 broker上面的 partition 在其他机器上都有副本的。如果这个宕机的 broker 上面有某个 partition 的 leader,那么此时会从 follower 中**重新选举**一个新的 leader 出来,大家继续读写那个新的 leader 即可。这就有所谓的高可用性了。
6060

6161
**写数据**的时候,生产者就写 leader,然后 leader 将数据落地写本地磁盘,接着其他 follower 自己主动从 leader 来 pull 数据。一旦所有 follower 同步好数据了,就会发送 ack 给 leader,leader 收到所有 follower 的 ack 之后,就会返回写成功的消息给生产者。(当然,这只是其中一种模式,还可以适当调整这个行为)
6262

0 commit comments

Comments
 (0)