搭建Kafka叢集

1. 啟動Zookeeper伺服器

2. 修改broker-1，broker-2配置

3. 啟動broker-1，broker-2伺服器

4. 檢視broker叢集

5. 建立并檢視topic

檢視topic

從控制台可以看出，總共建立了一個主題（第一行是彙總行，下面清單顯示的是詳細資訊）。

    leader：從分區中讀寫消息的節點。每個節點成為leader都是随機的。

    replicas：複制日志的節點，不管它是否是leader，也不管它是否還可用。

    isr：同步狀态的副本集。這個副本集包括活動者的以後可能成為leader的節點。

    現在看一下在單節點建立的主題test（如果沒有更好Zookeeper的話，之前建立的主題都存在）。我們發現根本沒有副本（Replicas: 0），因為副本隻有在叢集伺服器下才會建立。

6. 發送消息

7. 接收消息

8. 測試容錯機制，結束server-1的程序，檢視叢集主題。可以看到Leader節點已經轉移，而且server-1已經不在同步的複制集中。

9. 重新運作消費者仍能接收消息，盡管這些消息是由leader-1寫入的。