下载Kafka
《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
版权归原作者 Meta39 所有, 如有侵权,请联系我们删除。