1. 安装 Java
Kafka 是用 Java 编写的,所以第一步是确保 Java 已经安装
2. 下载并解压 Kafka
可以从 Apache Kafka 的官方网站下载最新版本的 Kafka(Binary 版本)。使用 wget 命令下载,然后用 tar 命令解压:
wget https://downloads.apache.org/kafka/3.6.0/kafka_2.12-3.6.0.tgztar -xzf kafka_2.12-3.6.0.tgzcd kafka_2.12-3.6.0
3. 启动 Zookeeper
Kafka 使用 Zookeeper 来管理集群元数据和协调。Kafka 自带一个 Zookeeper 实例,可以通过以下命令启动:
bin/zookeeper-server-start.sh config/zookeeper.properties
4. 启动 Kafka 服务器
在另一个终端,启动 Kafka 服务器:
bin/kafka-server-start.sh config/server.properties
5. 配置服务随系统启动时自启(可选)
通常涉及到编写 systemd 服务单元文件。以下是设置这些服务以实现自启动的步骤:
1. 创建 Systemd 服务文件
对于 ZooKeeper 和 Kafka,您需要创建两个服务文件。
ZooKeeper 服务文件
- 打开一个新的文件以创建 ZooKeeper 的 systemd 服务文件:
 
sudo nano /etc/systemd/system/zookeeper.service
- 将以下内容粘贴到文件中(确保根据您的 Kafka 安装路径进行适当修改):
 
[Unit]Description=Apache Zookeeper serverDocumentation=http://zookeeper.apache.orgRequires=network.targetAfter=network.target[Service]Type=simpleExecStart=/path/to/your/kafka/bin/zookeeper-server-start.sh /path/to/your/kafka/config/zookeeper.propertiesExecStop=/path/to/your/kafka/bin/zookeeper-server-stop.shRestart=on-abnormal[Install]WantedBy=multi-user.target
Kafka 服务文件
- 同样,创建 Kafka 的 systemd 服务文件:
 
sudo nano /etc/systemd/system/kafka.service
- 将以下内容粘贴到文件中(确保根据您的 Kafka 安装路径进行适当修改,并确保 ZooKeeper 服务已启动):
 
[Unit]Description=Apache Kafka ServerDocumentation=http://kafka.apache.org/documentation.htmlRequires=zookeeper.serviceAfter=zookeeper.service[Service]Type=simpleExecStart=/path/to/your/kafka/bin/kafka-server-start.sh /path/to/your/kafka/config/server.propertiesExecStop=/path/to/your/kafka/bin/kafka-server-stop.shRestart=on-abnormal[Install]WantedBy=multi-user.target
2. 启用和启动服务
使用以下命令启用并启动 ZooKeeper 和 Kafka 服务(记住这些操作,以后像mysql都是这么操作的):
--开启自启sudo systemctl enable zookeeper--关闭自启sudo systemctl disable zookeeper--启动服务器sudo systemctl start zookeeper--查看状态sudo systemctl status zookeeper--开启自启sudo systemctl enable kafka--关闭自启sudo systemctl disable kafka--启动服务器sudo systemctl start kafka--查看状态sudo systemctl status kafka