在 Ubuntu 22.04 LTS 上安装 Apache Kafka 3.7.0 的详细步骤如下:
1. 安装 Java
Kafka 需要 Java 环境,因此首先需要安装 Java。推荐使用 OpenJDK 11。
sudo apt update
sudo apt install openjdk-11-jdk -y
2. 验证 Java 安装
安装完成后,通过以下命令检查 Java 版本以确保安装成功:
java -version
3. 下载 Kafka,两种下载方式
3.1使用 wget 命令从 Apache Kafka 的官方网站下载 Kafka 3.7.0 的二进制包。
wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
3.2从官网下载 https://kafka.apache.org/downloads
kafka文件后缀名的区别
.tgz: 这是.tar.gz的缩写,表示该文件是一个使用gzip压缩的tar归档文件。tar是一个归档工具,可以将多个文件和目录合并成一个归档文件,而gzip是一个压缩工具。
.src.tgz: 与.tgz类似,但通常表示这是一个源代码包。src代表“source”,即源代码。下载这类文件后,需要自行编译源代码。
例如,kafka_2.12-2.7.0.tgz是一个针对Scala 2.12版本编译的Kafka 2.7.0的二进制发行版,而kafka-2.7.0-src.tgz则是包含Kafka 2.7.0版本源代码的压缩包。
在实际使用中,如果您需要从源代码开始编译Kafka,那么您需要下载src.tgz文件。如果您只是想安装并运行Kafka,那么下载tgz文件会更加方便。
4.解压下载的文件
将下载的 Kafka 二进制包解压到一个目录中,例如 /opt:
tar xvf kafka_2.13-3.7.0.tgz -C /opt
- 进入解压后的kafka的bin目录,手动启动 ZooKeeper 和 Kafka
前台启动zk :
sudo ./zookeeper-server-start.sh ../config/zookeeper.properties
或者以守护式进程启动,后台运行:
sudo ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
后台启动kafka:
sudo ./kafka-server-start.sh -daemon ../config/server.properties
手动启动 Kafka 中的 ZooKeeper 时,可以通过以下几种方式确认是否启动成功:
查看启动日志:
如果在终端中手动启动 ZooKeeper,启动日志会直接输出到终端。成功启动通常会显示 "ZooKeeper ... started" 或类似的信息。
检查进程列表:
使用 ps 命令查看 ZooKeeper 的进程是否在运行:
ps -ef | grep zookeeper
如果启动成功,应该能够看到 ZooKeeper 的 Java 进程。
检查端口监听:
使用 netstat 或 ss 命令检查 ZooKeeper 的端口(默认是 2181)是否被监听:
netstat -tuln | grep 2181
或者
ss -tuln | grep 2181
如果看到端口 2181 正在监听,说明 ZooKeeper 应该已经启动。
要检查 手动启动Kafka 是否启动成功,可以使用以下几种方法:
查看启动日志:
如果您在终端中手动启动 Kafka,启动日志会直接输出到终端。成功启动通常会显示 "Kafka Server ... started" 或类似的信息。
检查进程列表:
使用 ps 命令查看 Kafka 的进程是否在运行:
ps -ef | grep kafka
如果启动成功,您应该能够看到 Kafka 的 Java 进程。
查看 Kafka 日志文件:
检查 Kafka 的日志文件,通常位于 /opt/kafka/logs/ 或者您在配置文件中指定的其他位置。日志文件可能包含启动成功或失败的具体信息。
检查端口监听:
使用 netstat 或 ss 命令检查 Kafka 的端口(默认是 9092)是否被监听:
netstat -tuln | grep 9092
或者
ss -tuln | grep 9092
如果看到端口 9092 正在监听,说明 Kafka 应该已经启动。
版权归原作者 醒醒a 所有, 如有侵权,请联系我们删除。