** 通過下面的命令去創建帶2個副本的topic

sh kafka-topics.sh --create --zookeeper 192.168.11.156:2181 --replication-factor 3 --partitions 3 --topic secondTopic

然后我們可以在/tmp/kafka-log路徑下看到對應topic的副本信息了。我們通過一個圖形的方式來表達。

針對secondTopic這個topic的3個分區對應的3個副本

如何知道那個各個分區中對應的leader是誰呢？

在zookeeper服務器上，通過如下命令去獲取對應分區的信息, 比如下面這個是獲取secondTopic第1個分區的狀態信息。

get /brokers/topics/secondTopic/partitions/1/state

{"controller_epoch":12,"leader":0,"version":1,"leader_epoch":0,"isr":[0,1]} 或通過這個命令sh kafka-topics.sh --zookeeper 192.168.13.106:2181 --describe --topic test_partition

leader表示當前分區的leader是那個broker-id。下圖中。綠色線條的表示該分區中的leader節點。其他節點就為follower

需要注意的是，kafka集群中的一個broker中最多只能有一個副本，leader副本所在的broker節點的分區叫leader節點，follower副本所在的broker節點的分區叫follower節點

?

?

?

?

?

超強干貨來襲 云風專訪：近40年碼齡，通宵達旦的技術人生

總結

以上是生活随笔為你收集整理的创建一个带副本机制的topic的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。