kafka的安装

1. 下载及上传

此处使用Kafka的2.3.1版本进行安装，下载地址：http://kafka.apache.org/downloads

下载完成之后将下载好的kafka_2.11-2.3.1.tgz安装包上传到所要安装的Linux服务器上，我的软件安装包放在/opt/software/下

2. 安装

将Kafka_2.11-2.3.1.tgz解压在/opt/apps/目录下

[yangqi@xiaoer ~]$ tar -zvxf /opt/software/kafka_2.11-2.3.1.tgz -C /opt/apps/
[yangqi@xiaoer ~]$ cd /opt/apps/
# 进行更名处理，防止以后配置环境变量时方便
[yangqi@xiaoer apps]$ mv kafka_2.11-2.3.1/ kafka-2.3.1/

启动服务

kafka使用了zookeeper，因此在启动kafka之前，要先启动zookeeper服务（我已经启动了zookeeper服务）

直接启动kafka服务：

[yangqi@xiaoer apps]$ cd kafka-2.3.1/
[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties

一般情况下，首次启动kafka都会报错，显示JVM内存不足：

此时可以修改一下kafka-server-start.sh的配置，将JVM的内存调小一点

[yangqi@xiaoer kafka-2.3.1]$ vi ./bin/kafka-server.start.sh

再次重新启动kafka服务：

[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties

如果你们的集群和笔者的一样，zookeeper集群是单独安装的，并没有安装在master机器上，那么可能会出现以下错误，说明kafka在连接zookeeper时连接失败，可以修改./config/server.properties中的内容

修改内容如下：（修改成你自己的zookeeper集群的位置）

重新启动kafka服务：（如果没有报错则启动成功）

[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties

此时可以先使用Crtl+C结束kafka的相关服务

将kafka服务放到后台启动：

[yangqi@xiaoer kafka-2.3.1]$ nohup ./bin/kafka-server-start.sh ./config/server.properties >/dev/null 2>&1 &