〇、前言
在Kafka系列的上一篇文章中，我们介绍了Kafka的体系结构，那么本篇文章呢，我们就着手来把Kafka的运行环境搭建起来。
此处 ，我们采用线上环境普遍使用的ZooKeeper作为管理存储和管理kafka集群元数据，或者辅助Controller选举操作等。
那么，在管理界面的展示端，我们采用了EFAK（即：kafka-eagle）,所以这部分的安装步骤，我们也会在下文中展示出来。
一、安装ZooKeeper
首先，进入Zookeeper官网（https://zookeeper.apache.org/），下载你所需要的ZooKeeper版本，如下图所示：
然后，将下载下来的ZooKeeper解压到本地路径，进入ZooKeeper的conf目录下，复制zoo_sample.cfg配置文件，将其命名为zoo.cfg，如下图所示：
其中，zoo.cfg配置文件中各配置项的含义如下所示：
# zookeeper时间配置中的基本单位（毫秒）
tickTime=2000# 允许follower初始化连接到leader最大时长，它表示tickTime时间的倍数 即：initLimit*tickTime
initLimit=10# 运行follower与leader数据同步最大时长，它表示tickTime时间倍数 即：syncLimit*tickTime
syncLimit=5# zookeeper数据存储目录及日志保存目录（如果没有指明dataLogDir，则日志也保存在这个文件中）
dataDir=/tmp/zookeeper# 对客户端提供的端口号
clientPort=2181# 单个客户端于zookeeper最大并发连接数
maxClientCnxns=60# 保存的数据快照数量，之外的将会被清除
autopurge.snapRetainCount=3# 自动出发清除任务时间间隔，以小时为单位。默认为0，表示不自动清除
autopurge.purgeInterval=1## Metrics Providers
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true## ttl settings
extendedTypesEnabled=true## 由于AdminServer默认使用8080端口，此处修改为8888
admin.serverPort=8888
配置好zoo.conf配置文件后，我们就可以启动ZooKeeper了，如下图所示：
启动完ZooKeeper之后，我们也可以通过调用zkServer.sh status命令，来查看zookeeper的运行状态，如下图所示：
二、安装Kafka
上面我们安装完ZooKeeper之后，我们就可以开始着手安装Kafka了；
首先，进入Kafka官网下载kafka（http://kafka.apache.org/），如下图所示：
然后，将下载下来的Kafka解压到本地路径，然后进入config目录下，编辑 server.properties 配置文件，如下图所示：
server.properties 配置项解析如下所示：
| 属性 | 默认值 | 描述 |
| broker.id | 0 | 每个broker都可以用一个唯一的非负整数id进行标识；这个id可以作为broker的名字，你可以选择任意数字作为id，但是一定要保证唯一性； |
| log.dirs | /tmp/kafka-logs | kafka存放数据的路径。这个路径并不是唯一的，可以是多个，路径之间使用逗号分隔；每当创建新的partition时，都会选择在包含最少partitions的路径下进行； |
| listeners | PLAINTEXT://192.168.65.60:9092 | server接受客户端连接的端口，ip配置kafka本机ip即可 |
| zookeeper.connect | localhost:2181 | zookeeper连接字符串的格式为：hostname:port，此处分别对应zk集群中的节点；连接方式为:hostname1:port1,hostname2:port2,hostname3:port3 |
| log.retention.hours | 168 | 每个日志文件删除之前保存的时间。默认数据保存时间对所有topic都一样 |
| num.partitions | 1 | 创建topic的默认分区数 |
| default.replication.factor | 1 | 自动创建topic的默认副本数量，建立设置为大于等于2 |
| min.insync.replicas | 1 | 当producer设置acks=-1时，min.insync.replicas指定的最小数目（必须确认每一个repica的写数据都是成功的），如果这个数目没有达到，producer发送消息会产生异常 |
| delete.topic.enable | false | 是否允许删除主题 |
在以上的配置项中，我们最主要需要关注如下几个配置内容
【broker的序号】broker.id=0
【当前kafka的监听地址】listeners=PLAINTEXT://localhost:9092
【日志的存储路径】log.dirs=/Users/muse/kafka_2.13-3.0.0/kafka-logs
【zookeeper的服务地址】zookeeper.connect=localhost:2181
修改完相应的配置后，启动Kafka，并通过查看kafka的进程来判断是否启动起来了，如下图所示：
查看启动日志是否正常，如下图所示：
也可以链接ZooKeeper之后，在客户端的终端上面查看broker是否注册成功，如下图所示：
三、安装EFAK
最后，我们来安装一下Kafka的监控界面，首先进入EFAK官网下载Eagle (http://download.kafka-eagle.org/)，如下图所示：
修改EFAK的conf目录下配置文件——system-config.properties，如下图所示：
配置环境变量KE_HOME，并调用source .zshrc使其立即生效。（如果不配置的话，启动时会报错），如下图所示：
启动EFAK，如下图所示：
启动成功界面，如下图所示：
访问EFAK界面 (http://192.168.1.3:8048)，默认的用户名为admin，默认的密码为123456，如下图所示：
管理界面如下所示：
今天的文章内容就这些了：
写作不易，笔者几个小时甚至数天完成的一篇文章，只愿换来您几秒钟的 点赞 & 分享 。
更多技术干货，欢迎大家关注公众号“爪哇缪斯” ~ \(^o^)/ ~ 「干货分享，每天更新」
