kafka和zookeeper需要在有jdk的环境中才能安装。

 

安装zookeeper

1. 从http://zookeeper.apache.org/releases.html中下载zookeeper安装包

 

1. 解压下载的zookeeper安装包

tar -xzvf apache-zookeeper-3.6.0-bin.tar.gz

1. 进入apache-zookeeper-3.6.0-bin/conf，复制zoo_sample.cfg文件，修改文件名为zoo.cfg
2. 编辑配置文件

# zookeeper 服务器心跳时间，单位为ms

tickTIme=2000

# 投票选举新Leader 的初始化时间

initLimit=10

# leader 与follower 心跳检测最大容忍时间，

# 响应超过syncLimit*ticketTime,leader 认为follower死掉，

#从服务器列表中删除follower

syncLimit=5

# 数据目录

dataDir=/tmp/zookeeper/data  #修改为自己的数据目录

# 日志目录

dataLogDir=/tmp/zookeeper/log #修改为自己的日志目录

# 对外服务端口

clientPort=2181

1. 创建数据和日志目录，配置文件中的数据目录和日志目录需要手动创建。

mkdir -p /tmp/zookeeper/data

mkdir -p /tmp/zookeeper/log

 

1. 在数据目录下创建一个myid的文件，在里面写入0。

cd /tmp/zookeeper/data

vi myid

1. 启动zookeeper

cd apache-zookeeper-3.6.0-bin/bin/

zkServer.sh start

安装kafka

1. 从http://kafka.apache.org中下载kafka安装包

 

1. 解压下载的kafka安装包

tar -xzvf kafka_2.12-2.4.1.tar.gz

1. 进入kafka_2.12-2.4/config目录下，修改server.properties

# broker 的编号，如果集群中有多个broker,则每个broker 的编号要设置的不同

broker.id=0

# 对外提供的服务入口地址

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://192.31.172.75:9092 #修改为外网ip

# 存放消息的日志文件

log.dirs=/tmp/kafka-logs/

# kafka所需要的Zookeeper集群地址

zookeeper.connect=localhost:2181/kafka

1. 启动kafka

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

 

 

注：

如果zookeeper连接失败：

可能是因为防火墙原因

显示防火墙状态：
systemctl status firewalld
关闭防火墙
systemctl stop firewalld