1. 安装 Java

Kafka 是用 Java 编写的,所以第一步是确保 Java 已经安装

2. 下载并解压 Kafka

可以从 Apache Kafka 的官方网站下载最新版本的 Kafka(Binary 版本)。使用 wget 命令下载,然后用 tar 命令解压:
  1. wget https://downloads.apache.org/kafka/3.6.0/kafka_2.12-3.6.0.tgz
  2. tar -xzf kafka_2.12-3.6.0.tgz
  3. cd kafka_2.12-3.6.0

3. 启动 Zookeeper

Kafka 使用 Zookeeper 来管理集群元数据和协调。Kafka 自带一个 Zookeeper 实例,可以通过以下命令启动:
  1. bin/zookeeper-server-start.sh config/zookeeper.properties

4. 启动 Kafka 服务器

在另一个终端,启动 Kafka 服务器:
  1. bin/kafka-server-start.sh config/server.properties

5. 配置服务随系统启动时自启(可选)

通常涉及到编写 systemd 服务单元文件。以下是设置这些服务以实现自启动的步骤:

1. 创建 Systemd 服务文件

对于 ZooKeeper 和 Kafka,您需要创建两个服务文件。

ZooKeeper 服务文件

  1. 打开一个新的文件以创建 ZooKeeper 的 systemd 服务文件:
  1. sudo nano /etc/systemd/system/zookeeper.service
  1. 将以下内容粘贴到文件中(确保根据您的 Kafka 安装路径进行适当修改):
  1. [Unit]
  2. Description=Apache Zookeeper server
  3. Documentation=http://zookeeper.apache.org
  4. Requires=network.target
  5. After=network.target
  6. [Service]
  7. Type=simple
  8. ExecStart=/path/to/your/kafka/bin/zookeeper-server-start.sh /path/to/your/kafka/config/zookeeper.properties
  9. ExecStop=/path/to/your/kafka/bin/zookeeper-server-stop.sh
  10. Restart=on-abnormal
  11. [Install]
  12. WantedBy=multi-user.target

Kafka 服务文件

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

2. 启用和启动服务

使用以下命令启用并启动 ZooKeeper 和 Kafka 服务(记住这些操作,以后像mysql都是这么操作的):
  1. --开启自启
  2. sudo systemctl enable zookeeper
  3. --关闭自启
  4. sudo systemctl disable zookeeper
  5. --启动服务器
  6. sudo systemctl start zookeeper
  7. --查看状态
  8. sudo systemctl status zookeeper
  9. --开启自启
  10. sudo systemctl enable kafka
  11. --关闭自启
  12. sudo systemctl disable kafka
  13. --启动服务器
  14. sudo systemctl start kafka
  15. --查看状态
  16. sudo systemctl status kafka