本文環(huán)境如下：
操作系統(tǒng)：CentOS 6 32位
JDK版本：1.8.0_77 32位
Kafka版本：0.9.0.1(Scala 2.11)

接上篇 Kafka單機(jī)、集群模式安裝詳解(一)

6. 單節(jié)點(diǎn)多Broker模式

Kafka使用可以有多種模式，包括單節(jié)點(diǎn)單Broker,單節(jié)點(diǎn)多Broker,多節(jié)點(diǎn)多Broker。
這里我們簡單區(qū)分一下：
單節(jié)點(diǎn)單Broker：在單臺機(jī)子上，啟動了一個Kafka實(shí)例（上一篇就是這種模式）。
單節(jié)點(diǎn)多Broker：在同一臺機(jī)子上開啟多個Kafka（類似Hadoop的偽分布式）。
多節(jié)點(diǎn)多Broker：在多臺機(jī)子上分別開啟多個Kafka。

6.1 復(fù)制Kafka

將上一篇單節(jié)點(diǎn)單Broker的Kafka文件夾復(fù)制1份為Kafka2。

6.2 修改配置文件

（1）修改第一個Kafka的server.properties中的以下內(nèi)容：

broker.id=0 port=9092 host.name=master

（2）修改第二個Kafka的server.properties中的以下內(nèi)容：

broker.id=1 port=9093 //端口號要與其他同主機(jī)的實(shí)例不同 host.name=master

6.3 啟動程序

先要確保zookeeper已啟動，然后分別在2個Kafka的目錄執(zhí)行

bin/kafka-server-start.sh config/server.properties&

如果無報錯則說明啟動成功

7. 分布模式（多節(jié)點(diǎn)多Broker）

7.1 復(fù)制Kafka

將第六步的Kafka文件夾復(fù)制2份到另外2臺服務(wù)器上slave1和slave2，分別為Kafka3，Kafka4。

7.2 修改配置文件

（1）修改第三個Kafka的server.properties中的以下內(nèi)容：

broker.id=2 port=9092 host.name=slave1

（2）修改第四個Kafka的server.properties中的以下內(nèi)容：

broker.id=3 port=9092 host.name=slave2

7.3 啟動程序

先要確保zookeeper已啟動，然后分別在3臺主機(jī)上所有的Kafka目錄執(zhí)行

bin/kafka-server-start.sh config/server.properties&

如果無報錯則說明啟動成功

總結(jié)

以上是生活随笔為你收集整理的Kafka单机、集群模式安装详解(二)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。