- 官网下载安装包后，版本：kafka_2.13-3.9.1
如：放在如下路径下
/opt/kafka_2.13-4.0.0
- 在 /opt/kafka_2.13-3.9.1/config 下修改日志路径，避免被清空，如：
log.dirs=/opt/kafka_2.13-4.0.0/kraft-combined-logs
- 设置环境变量
vim /etc/profile
KAFKA_HOME=/opt/kafka_2.13-4.0.0
PATH=$JAVA_HOME/bin:$GOROOT/bin:$KAFKA_HOME/bin:$PATH
source /etc/profile
启动Kafka环境
- 注意：本地环境必须安装了Java 8+；
- Apache Kafka可以使用ZooKeeper或KRaft启动；但只能使用其中一种方式，不能同时使用；
- KRaft：Apache Kafka的内置共识机制，用于取代 Apache ZooKeeper；
1. Kafka启动使用Zookeeper
- 在bin目录下启动zookeeper：
./zookeeper-server-start.sh ../config/zookeeper.properties &
- 查看zk进程
ps -ef|grep zookeeper
- 查看zk端口号
netstat -nlpt
或者单独下载个zk启动，不使用kafka内置的zk，可以参考我写的这篇文章：
Zookeeper 3.8.4 安装和参数解析
- 启动kafka
./kafka-server-start.sh ../config/server.properties &
- 查看 Kafka 端口号，默认 9092
netstat -nlpt
可以看到上面 zk 和 kafka 的 pid 分别占用了两个端口号
- 关闭Kafka
./kafka-server-stop.sh ../config/server.properties
- 关闭zookeeper
./zookeeper-server-stop.sh ../config/zookeeper.properties
2. Zookeeper的下载和安装
- 详细安装请参考如下
Windows下安装：Windows下安装zookeeper
Linux下安装：Zookeeper 3.8.4 安装和参数解析下面简单介绍下
- 获取Zookeeper
- 下载最新版本的Zookeeper：https://zookeeper.apache.org/
- 安装Zookeeper
tar -xzf apache-zookeeper-3.9.2-bin.tar.gz -C /usr/local/
cd apache-zookeeper-3.9.2-bin
- 配置Zookeeper
cp zoo_sample.cfg zoo.cfg
- zoo.cfg 不需要修改，直接使用即可；
- 启动Zookeeper
启动：zkServer.sh start 关闭：zkServer.sh stop
- 可以看到 zk 启动的进程占用了如下三个端口号
- zookeeper启动默认会占用8080端口，修改配置文件，添加如下配置：
vim zoo.cfg
admin.serverPort=9089
- 在配置文件最后一行加上
- zk启动后，再启动Kafka
./kafka-server-start.sh ../config/server.properties &
- 在 Kafka 的 config 目录中的 server.properties 可以看到连接 zk 的配置
3. Kafka启动使用KRaft
1、生成Cluster UUID（集群UUID）：
- 在 Kafka 中的 bin 目录下
- 可以看下怎么使用
./kafka-storage.sh random-uuid
- info 命令使用
./kafka-storage.sh info -c ../config/kraft/server.properties
2、格式化日志目录：
- 查看命令介绍
./kafka-storage.sh format -t 8tLx5xkqSWOZq1X4xHsY6Q -c ../config/kraft/server.properties
3、启动Kafka：
./kafka-server-start.sh ../config/kraft/server.properties &
- 查看 Kafka 进程占用的端口号
- Kafka占用的 9002、9003 端口是固定的，还有一个端口号是随机的
- 查看 info 信息
./kafka-storage.sh info -c ../config/kraft/server.properties
4、关闭Kafka：
./kafka-server-stop.sh ../config/kraft/server.properties
