docs: fix typo

This commit is contained in:
yanglbme 2018-12-23 17:13:24 +08:00
parent d76283a23e
commit 8747eeb7f2
5 changed files with 1 additions and 1 deletions

View File

@ -54,7 +54,7 @@ Kafka 0.8 以前,是没有 HA 机制的,就是任何一个 broker 宕机了
Kafka 0.8 以后,提供了 HA 机制,就是 replica复制品 副本机制。每个 partition 的数据都会同步到其它机器上,形成自己的多个 replica 副本。所有 replica 会选举一个 leader 出来,那么生产和消费都跟这个 leader 打交道,然后其他 replica 就是 follower。写的时候leader 会负责把数据同步到所有 follower 上去,读的时候就直接读 leader 上的数据即可。只能读写 leader很简单**要是你可以随意读写每个 follower那么就要 care 数据一致性的问题**系统复杂度太高很容易出问题。Kafka 会均匀地将一个 partition 的所有 replica 分布在不同的机器上,这样才可以提高容错性。
![kafka-after](/img/kakfa-after.png)
![kafka-after](/img/kafka-after.png)
这么搞,就有所谓的**高可用性**了,因为如果某个 broker 宕机了,没事儿,那个 broker上面的 partition 在其他机器上都有副本的,如果这上面有某个 partition 的 leader那么此时会从 follower 中**重新选举**一个新的 leader 出来,大家继续读写那个新的 leader 即可。这就有所谓的高可用性了。

View File

Before

Width:  |  Height:  |  Size: 36 KiB

After

Width:  |  Height:  |  Size: 36 KiB

View File

Before

Width:  |  Height:  |  Size: 12 KiB

After

Width:  |  Height:  |  Size: 12 KiB

View File

Before

Width:  |  Height:  |  Size: 36 KiB

After

Width:  |  Height:  |  Size: 36 KiB

View File

Before

Width:  |  Height:  |  Size: 12 KiB

After

Width:  |  Height:  |  Size: 12 KiB