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.tgz
tar -xzf kafka_2.12-3.6.0.tgz
cd 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 server
Documentation=http://zookeeper.apache.org
Requires=network.target
After=network.target
[Service]
Type=simple
ExecStart=/path/to/your/kafka/bin/zookeeper-server-start.sh /path/to/your/kafka/config/zookeeper.properties
ExecStop=/path/to/your/kafka/bin/zookeeper-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
Kafka 服务文件
- 同样,创建 Kafka 的 systemd 服务文件:
sudo nano /etc/systemd/system/kafka.service
- 将以下内容粘贴到文件中(确保根据您的 Kafka 安装路径进行适当修改,并确保 ZooKeeper 服务已启动):
[Unit]
Description=Apache Kafka Server
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service
After=zookeeper.service
[Service]
Type=simple
ExecStart=/path/to/your/kafka/bin/kafka-server-start.sh /path/to/your/kafka/config/server.properties
ExecStop=/path/to/your/kafka/bin/kafka-server-stop.sh
Restart=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