安装Kafka的步骤 启动Kadfka 关闭Kafka

2021年09月15日 阅读数:1
这篇文章主要向大家介绍安装Kafka的步骤 启动Kadfka 关闭Kafka,主要内容包括基础应用、实用技巧、原理机制等方面,希望对大家有所帮助。

安装Kafka

1 )解压安装包java

[yanxiaodai@master packge]$ tar -zxvf kafka_2.11-0.11.0.0.tgz -C /home/yanxiaodai/module

2 )修改解压后的文件名称bash

[yanxiaodai@master module]$ mv kafka_2.11-0.11.0.0.tgz kafka

3 )在kafka目录下建立logs文件spa

[yanxiaodai@master kafka]mkdir logs

4 )修改配置文件日志

[yanxiaodai@master kafka]cd config/
[yanxiaodai@master config]sudo vi server.properties

修改如下的文件code

#broker的全局惟一编号,不能重复
broker.id=0
#删除topic功能使能
delete.topic.enable=true
#kafka运行日志存放的路径
log.dirs=/home/yanxiaodai/module/kafka/logs
#配置链接Zookeeper集群地址
zookeeper.connect=master:2181,service01:2181,service02:2181

5 )配置环境变量server

[yanxiaodai@master module]$ sudo vi /etc/profile

#KAFKA_HOME
export KAFKA_HOME=/home/yanxiaodai/module/kafka
export PATH=$PATH:$KAFKA_HOME/bin

刷新文件进程

[yanxiaodai@master module]$ source /etc/profile

6 )分发安装包kafka

[yanxiaodai@master module]$ scp -r kafka/ yanxiaodai@service01:/home/yanxiaodai/module/

[yanxiaodai@master module]$ scp -r kafka/ yanxiaodai@service02:/home/yanxiaodai/module/

7 )分别在service0一、service02上修改配置文件ast

[yanxiaodai@service01 kafka]cd config/
[yanxiaodai@service01 config]sudo vi server.properties

#broker的全局惟一编号,不能重复
broker.id=1
[yanxiaodai@service02 kafka]cd config/
[yanxiaodai@service02 config]sudo vi server.properties

#broker的全局惟一编号,不能重复
broker.id=2

8 )启动
启动kafka以前先要启动zookeeper
class

依次在master、service0一、service02节点上启动kafka

[yanxiaodia@mster kafka]$ bin/kafka-server-start.sh config/server.properties &
[yanxiaodai@service kafka]$ bin/kafka-server-start.sh config/server.properties &
[yanxiaodai@service kafka]$ bin/kafka-server-start.sh config/server.properties &

9 )关闭
关闭kafka时,显示报错:No kafka server to stop。
应当修改 kafka-server-stop.sh 脚本

[yanxiaodia@mster bin]$ sudo vi kafka-server-stop.sh
修改前:
PIDS=$(ps ax | grep -i 'kafka.Kafka' | grep java | grep -v grep | awk '{print $1}')
修改后:
PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}')

使用ps -lm命令列出全部的java进程,而后经过管道,利用grep -i 'kafka.Kafka'命令将kafka进程筛出来,最后再接一管道命令,利用awk将进程号取出来。