前言：本文以一台服务器来搭建集群示例。

Kafka官方网址：Apache Kafka

点击Download下载需要的版本：

 下载后的文件：

 将下载后的文件上传到服务器中指定的位置：

将文件分别解压到三个文件夹中：

首先先对node1进行配置文件修改，修改config中的server.properties文件：

注意：对于绑定的监听地址有时候直接在浏览器输入node1不识别，写全称如node1.test.cn

同理，将node1上述操作在node2和node3中做同样的操作：

注意：记得kafka_data文件夹不存在时要先新建。

修改hosts文件：

注意：如果对外开放的话，这儿的127.0.0.1要改为0.0.0.0

配置KAFKA_HOME环境变量：

加载环境变量：

启动服务器，首先启动ZooKeeper：

注意：因为测试使用的是同一台服务器，在这儿启动一个node的zookeeper即可。

注意：如果服务器没有安装java环境时，启动zookeeper会报错。

启动Kafka：

同理：启动node2和node3。

测试Kafka集群是否启动成功：

启动成功后，日志文件也对应的生成了：

为了可视化查看Kafka集群启动状况，可以下载可视化工具ZooInspector：

下载链接：https://issues.apache.org/jira/secure/attachment/12436620/ZooInspector.zip

在上面Kafka启动成功后，我们需要以后台形式的启动Kafka，可以借助工具nohup来后台启动。

为了方便快速的启动所有的程序，可以把命令写到一个脚本中进行执行，如下所示：

注意事项：

zookeeper和Kafka启动过程中内存可能占用的比较多，可以对内存大小进行修改。