Kafka单机、集群模式安装详解(二)

本文环境如下：
操作系统：CentOS 6 32位
JDK版本：1.8.0_77 32位
Kafka版本：0.9.0.1(Scala 2.11)

接上篇 Kafka单机、集群模式安装详解(一)

6. 单节点多Broker模式

Kafka使用可以有多种模式，包括单节点单Broker,单节点多Broker,多节点多Broker。
这里我们简单区分一下：
单节点单Broker：在单台机子上，启动了一个Kafka实例（上一篇就是这种模式）。
单节点多Broker：在同一台机子上开启多个Kafka（类似Hadoop的伪分布式）。
多节点多Broker：在多台机子上分别开启多个Kafka。

6.1 复制Kafka

将上一篇单节点单Broker的Kafka文件夹复制1份为Kafka2。

6.2 修改配置文件

（1）修改第一个Kafka的server.properties中的以下内容：

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

（2）修改第二个Kafka的server.properties中的以下内容：

broker.id=1
port=9093 //端口号要与其他同主机的实例不同
host.name=master

6.3 启动程序

先要确保zookeeper已启动，然后分别在2个Kafka的目录执行

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

如果无报错则说明启动成功

7. 分布模式（多节点多Broker）

7.1 复制Kafka

将第六步的Kafka文件夹复制2份到另外2台服务器上slave1和slave2，分别为Kafka3，Kafka4。

7.2 修改配置文件

（1）修改第三个Kafka的server.properties中的以下内容：

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

（2）修改第四个Kafka的server.properties中的以下内容：

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

7.3 启动程序

先要确保zookeeper已启动，然后分别在3台主机上所有的Kafka目录执行

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

如果无报错则说明启动成功

最后

以上就是瘦瘦自行车为你收集整理的Kafka单机、集群模式安装详解(二)的全部内容，希望文章能够帮你解决Kafka单机、集群模式安装详解(二)所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。