Linux之Kafka保姆式详细安装教程-Toy模板网

这篇具有很好参考价值的文章主要介绍了Linux之Kafka保姆式详细安装教程。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

下载Kafka

《Kafka官网下载》
注意：下载的是二进制文件，不要下载源码！这里可以采用第三方下载工具加速下载，如：迅雷等
Linux之Kafka保姆式详细安装教程,消息队列：rabbitmq、kafka、rocketmq,操作系统：linux、windows,linux,kafka,运维

上传到Linux服务器的/data/目录下进行解压

tar -zxvf是解压文件命令，-C表示把解压文件放到哪个目录下

tar -zxvf /data/kafka_2.12-3.5.0.tgz -C /data/

启动Kafka

修改环境变量

vim /etc/profile

export PATH USER LOGNAME MAIL HOSTNAME HISTSIZE HISTCONTROL下追加内容：

#kafka
export KAFKA_HOME=/data/kafka_2.12-3.5.0
export PATH=$PATH:$KAFKA_HOME/bin

按ESC键后输入:wq保存，使环境变量生效

source /etc/profile

修改配置文件

查看hostname，然后我的hostname就是node1

hostname

vim /data/kafka_2.12-3.5.0/config/kraft/server.properties

process.roles=broker,controller
#如果是集群，则node.id必须唯一
node.id=1
#控制角色选举值=node.id@node1:9093
controller.quorum.voters=1@node1:9093
#客户端ip/服务器名称:port
advertised.listeners=PLAINTEXT://node1:9092
#数据存放目录
log.dirs=/data/kafka_2.12-3.5.0/data

修改启动参数

vim /data/kafka_2.12-3.5.0/bin/kafka-server-start.sh

修改内存大小（默认1G，正式环境为了提升性能应该尽可能大。）

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx256m -Xms256m"
fi

启动kafka

编写启动kafka脚本

vim /data/kafka_2.12-3.5.0/reStartKafka.sh

确保进入到了kafka的安装目录下

#!/bin/bash
. /etc/profile
KAFKA_PATH="/data/kafka_2.12-3.5.0"
echo 'restart kafka'
pid=$(ps -ef|grep kafka|grep -w ${KAFKA_PATH}|grep -v 'grep'|awk '{print $2}')
if [ -n "$pid" ]
then
echo 'kafka is running,kill $pid'
kill -9 $pid
fi
sleep 3
rand=`${KAFKA_PATH}/bin/kafka-storage.sh random-uuid`
echo $rand
${KAFKA_PATH}/bin/kafka-storage.sh format -t $rand -c ${KAFKA_PATH}/config/kraft/server.properties
nohup ${KAFKA_PATH}/bin/kafka-server-start.sh ${KAFKA_PATH}/config/kraft/server.properties >/dev/null 2>log &
echo 'restart kafka finish'

授予可执行权限

chmod +x /data/kafka_2.12-3.5.0/reStartKafka.sh

软连接

ln -s /data/kafka_2.12-3.5.0/reStartKafka.sh /usr/bin

启动kafka

sh /data/kafka_2.12-3.5.0/reStartKafka.sh

等待几秒后查看kafka是否启动成功，太快可能会打印-- main class information unavailable

jps

成功则会打印如下信息

# pid | name
12337 Kafka
12788 Jps

停止kafka

查看kafka pid

netstat -ntlp | grep java

根据pid杀死kafka进程

kill -9 pid

重启kafka

sh reStartKafka.sh

补充说明

有人说找不到kafka-storage.sh这个shell脚本，其实他是这个版本kafka对应bin目录下自带的
Linux之Kafka保姆式详细安装教程,消息队列：rabbitmq、kafka、rocketmq,操作系统：linux、windows,linux,kafka,运维文章来源地址https://www.toymoban.com/news/detail-538573.html