在 Linux 上配置 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
为 Kafka 创建日志存储目录:
mkdir -p /usr/local/kafka/log/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
为 Zookeeper 创建数据和日志存储目录:
mkdir -p /usr/local/kafka/zookeeper/data
mkdir -p /usr/local/kafka/zookeeper/log
进入 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
进入 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 &
保存并退出。
立即执行启动脚本以测试:
/usr/local/kafka/kafkastart.sh
检查 Kafka 是否成功启动,可以使用 jps
命令查看进程列表,确认 Kafka 和 Zookeeper 是否在运行:
jps
通过以上步骤,您可以在 Linux 环境下成功安装并配置 Kafka。