這篇文章主要講解了“ KAFKA中的Replica是什么”，文中的講解內(nèi)容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“ KAFKA中的Replica是什么”吧！

專注于為中小企業(yè)提供成都網(wǎng)站設(shè)計、網(wǎng)站制作服務(wù),電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)東臺免費做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了上千企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴充和轉(zhuǎn)變。

【能否說下Replica的主從設(shè)計？】

冗余，可以理解為一個動作，就是把一份數(shù)據(jù)多拷貝了幾份出來。

而拷貝出來的數(shù)據(jù)我們就稱之為副本，這也是Replica的真正含義，那么多副本之間就必然存在著數(shù)據(jù)同步的問題：

也就是不同副本之間，以哪個副本的數(shù)據(jù)為準，如何保持數(shù)據(jù)一致這兩個主要問題。

因此，副本之間就有了主從的一個設(shè)計，負責提供讀寫的副本是leader，而其余的副本稱之為follower，follower副本只需要從leader副本那里一直拉取數(shù)據(jù)就好了，正常情況下不需要提供讀寫。

看起來是這個樣子的：

【能否說下Replica解決了什么問題？】

首先我們要明白一點——某個Partition的數(shù)據(jù)副本，都是分布在不同的broker上的，也就是說是分布在不同機器上的，那么顯而易見，Replica是為了解決單點問題而設(shè)計的。

我們再考慮下會存在哪些單點問題？

1、當我們生產(chǎn)消息的時候，如果數(shù)據(jù)只寫入了一個broker就返回了，那么一旦那個broker掛了，或者所在機器宕機了，是不是可能造成我剛才寫入的消息就丟失了？

2、我們生產(chǎn)/消費都只針對leader-replica進行，那么是不是一旦leader所在的broker掛了，或者所在機器宕機了，就無法進行生產(chǎn)消費了？

以上就是主要存在的兩個問題，在引入副本的設(shè)計后，解決這兩個問題就很簡單了：

1、由于存在多副本，因此我們可以設(shè)置寫入所有副本后，才算寫入消息成功；那么數(shù)據(jù)就會分散到多個節(jié)點上，從而避免了單點問題。這就是之前提到的實現(xiàn)了消息的高可靠。

2、由于存在多個副本，并且副本之間的數(shù)據(jù)一直在同步，一旦leader所在節(jié)點出現(xiàn)問題，那么我們就可以進行主備切換，讓某個follower成為新的leader來繼續(xù)提供讀寫，從而避免了整個服務(wù)不可用了。這就是之前提到的實現(xiàn)服務(wù)的高可用。

感謝各位的閱讀，以上就是“ KAFKA中的Replica是什么”的內(nèi)容了，經(jīng)過本文的學習后，相信大家對 KAFKA中的Replica是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！