在 Linux 上配置 Kafka 的步骤如下:
1. 下载并解压 Kafka
首先,访问 Apache Kafka 官方网站 下载适合您的 Linux 版本的 Kafka 安装包。例如,下载 kafka_2.12-3.3.2.tgz
。
cd /usr/local/src wget https://downloads.apache.org/kafka/3.3.2/kafka_2.12-3.3.2.tgz
然后解压安装包:
tar -zxvf kafka_2.12-3.3.2.tgz
将解压后的文件夹移动到合适的目录,例如 /usr/local/kafka
:
mv kafka_2.12-3.3.2 /usr/local/kafka
2. 配置 Kafka
创建日志目录
为 Kafka 创建日志存储目录:
mkdir -p /usr/local/kafka/log/kafka
编辑 Kafka 配置文件
进入 Kafka 的配置目录并编辑 server.properties
文件:
cd /usr/local/kafka/config vi server.properties
修改以下配置参数:
broker.id
: 设置 Kafka broker 的唯一标识符。listeners
: 设置 Kafka 监听的地址和端口。log.dirs
: 设置 Kafka 日志存储的目录。zookeeper.connect
: 设置 Zookeeper 连接地址。
示例配置:
broker.id=0 listeners=PLAINTEXT://192.168.1.100:9092 log.dirs=/usr/local/kafka/log/kafka zookeeper.connect=localhost:2181
3. 配置 Zookeeper
创建数据和日志目录
为 Zookeeper 创建数据和日志存储目录:
mkdir -p /usr/local/kafka/zookeeper/data mkdir -p /usr/local/kafka/zookeeper/log
编辑 Zookeeper 配置文件
进入 Zookeeper 的配置目录并编辑 zookeeper.properties
文件:
cd /usr/local/kafka/config vi zookeeper.properties
修改以下配置参数:
dataDir
: 设置 Zookeeper 数据存储的目录。dataLogDir
: 设置 Zookeeper 日志存储的目录。clientPort
: 设置 Zookeeper 客户端连接端口。
示例配置:
dataDir=/usr/local/kafka/zookeeper/data dataLogDir=/usr/local/kafka/zookeeper/log clientPort=2181
4. 启动 Kafka 和 Zookeeper
创建启动脚本
进入 Kafka 的安装目录并编辑 kafkastart.sh
文件:
cd /usr/local/kafka vi kafkastart.sh
添加启动 Zookeeper 和 Kafka 的命令:
#!/bin/sh /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties & sleep 3 /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &
为脚本添加执行权限:
chmod +x kafkastart.sh
创建关闭脚本
编辑 kafkastop.sh
文件:
vi kafkastop.sh
添加关闭 Zookeeper 和 Kafka 的命令:
#!/bin/sh /usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties & sleep 3 /usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &
为脚本添加执行权限:
chmod +x kafkastop.sh
设置开机自动启动
编辑 /etc/rc.local
文件,在文件末尾添加启动脚本,使其在开机时自动运行:
vi /etc/rc.d/rc.local
添加以下行:
/usr/local/kafka/kafkastart.sh &
保存并退出。
5. 验证安装
立即执行启动脚本以测试:
/usr/local/kafka/kafkastart.sh
检查 Kafka 是否成功启动,可以使用 jps
命令查看进程列表,确认 Kafka 和 Zookeeper 是否在运行:
jps
通过以上步骤,您可以在 Linux 环境下成功安装并配置 Kafka。