Linux环境下(Centos7) 下安装Kafka/Zookeeper 详细教程

Linux环境下(Centos7) 下安装Kafka详细教程

本博文讲解的为单机版安装教程

一. 安装Zookeeper

1.1 选择镜像：

• 清华镜像

• 阿里镜像

可以在上面两个地方选一个合适的镜像

1.2 安装步骤

1. 创建文件夹：

   mkdir -p /usr/local/services/zookeeper
   1

2. 进入文件夹:

   cd /usr/local/services/zookeeper
   1

3. 下载镜像至新建的文件夹：

   wget --no-check-certificate  https://mirrors.aliyun.com/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz
   1

   此处的zookeeper版本可能已经失效了，同学们可在镜像网站内选择合适的zookeeper版本，然后以此命令替换掉 镜像源下载即可。

4. 解压下载好的zookeeper，并进入解压完成后的新文件夹

   cd /usr/local/services/zookeeper
   1

   tar -zxf  zookeeper-3.4.10.tar.gz
   1

   cd zookeeper-3.4.10
   1

5. 进入到解压的文件夹后，创建data文件夹，用于存储数据文件；创建logs文件夹，用于存储日志：

   mkdir data
   1

   mkdir logs
   1

6. 创建配置文件zoo.cfg

   vim conf/zoo.cfg
   1

   tickTime = 2000
   dataDir = /usr/local/services/zookeeper/zookeeper-3.4.10/data
   dataLogDir = /usr/local/services/zookeeper/zookeeper-3.4.10/logs
   tickTime = 2000
   clientPort = 2181
   initLimit = 5
   syncLimit = 2
   1
   2
   3
   4
   5
   6
   7

   使用命令 vim conf/zoo.cfg 创建配置文件并打开,虽然文件夹下有了一个zoo_sample.cfg示例配置文件，我们还是新创建一个。至此以安装结束

1.3 常用命令如下：

1. 启动服务：

   /usr/local/services/zookeeper/zookeeper-3.4.10/bin/zkServer.sh start
   1

2. 连接服务：

   /usr/local/services/zookeeper/zookeeper-3.4.10/bin/zkCli.sh
   1

3. 查看服务状态：

   /usr/local/services/zookeeper/zookeeper-3.4.10/bin/zkServer.sh status
   1

4. 停止服务：

   /usr/local/services/zookeeper/zookeeper-3.4.10/bin/zkServer.sh stop
   1

二. 安装Kafka

2.1 安装前的准备

1. 全新安装的Centos-7 需要安装必要的依赖：

   yum install -y vim maven wget 
   1

2. 下载

• Kafka下载地址

  如果此地址无法访问或者下载速度较慢，可自行网络寻找Kafka压缩包，虽然版本不一样但是安装命令是基本一致的。

2.2 安装步骤

1. 下载

   wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.2.0/kafka_2.11-2.2.0.tgz
   1

2. 解压

   tar -zxvf kafka_2.11-2.2.0.tgz
   1

3. 进入目录并新建server.properties:

   cd kafka_2.11-2.2.0
   1

   vim config/server.properties
   1

4. 在broker.id= 0 后面增加如下配置：

   advertised.listeners=PLAINTEXT://192.168.29.128:9092
   1

   这里的192.168.29.128 替换为自己实际服务器ip， 此处端口号默认为9092

2.3 常用命令

1. 启动：

   bin/kafka-server-start.sh -daemon config/server.properties
   1

2. 停止：

   bin/kafka-server-stop.sh
   1

2.4 开放端口（可选）

• 如果Kafka是需要被其他服务器所访问的，则需要开放端口号；
• 开放端口可参考博主另外一篇文章： Linux工作常用命令

三. 后续关注点

• Kafka我们可以通过安装客户端工具进行连接，能够查询Kafka状态是否正常，每个Topic推送了多少数据等；工具有： Kafka Tool等，可自行百度。
• 我们通过Java程序使用Kafka，可参考博主的另外一篇文章： 实战：Spring Cloud Stream 集成Kafka