kafka的安装

￡神魔★判官ぃ 2023-01-05 12:07 56阅读 0赞

# 准备 #

**1、三台虚拟机（必须）**

**2、三台虚拟机都需要装有jdk（必须）**

[jdk的安装][jdk]

**3、三台虚拟机都需要有zookeeper（必须）**

[zookeeper的安装][zookeeper]

**4、vim安装 可以看配置文件效果更好（非必须）**

[vim的安装][vim]

# 1、下载 #

## 1.1、官网下载地址 ##

https://www.apache.org/dyn/closer.cgi?path=/kafka/2.4.1/kafka_2.11-2.4.1.tgz

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70]

## 1.2、百度网盘下载地址 ##

链接：https://pan.baidu.com/s/1HL3kuSocJT-zxjiniNeyQQ 
    提取码：2mqh

# 2、新建文件夹 #

在三台机器上都输入指令

cd /usr/local/

mkdir kafka

cd kafka

![在这里插入图片描述][2021011209341639.png]

# 3、上传/解压(以下配置为一台机器) #

**上传 这里我用了堡塔(参考这篇文章 的软件[jdk安装及堡塔软件的安装][jdk])，把刚刚下载的文件上传到kafka下**

## 3.1、上传 ##

![在这里插入图片描述][20210112093247301.png]  
![在这里插入图片描述][20210112093436227.png]

## 3.2、解压\\重命名 ##

![在这里插入图片描述][20210112093527487.png]  
**解压**

tar -zxvf kafka_2.11-2.4.1.tgz

**重命名**

mv kafka_2.11-2.4.1 kafka

cd kafka

![详细图][20210112093915227.png]

# 4、配置 配置文件 #

## 4.1、进入配置文件目录并 编辑 ##

**进入**

cd /usr/local/kafka/kafka/config/

**编辑**

vim server.properties

第一台机器

# 实例id不可以重复
    broker.id=0
    # 配置kafka的host和port 
    # 格式 listeners=PLAINTEXT://当前主机ip:端口号
    listeners=PLAINTEXT://192.168.73.139:9092
    # kafka数据的存放目录
    log.dirs=/usr/local/kafka/kafka/logs
    # zookeeper集群的ip和端口，用英文逗号进行分隔
    zookeeper.connect=192.168.73.139:2181,192.168.73.140:2182,192.168.73.141:2183
    # 在配置文件中添加如下配置，表示允许删除topic
    delete.topic.enable=true

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 1]

## 4.2、修改内存大小 ##

cd /usr/local/kafka/kafka/bin/

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 2]

vim kafka-server-start.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 3]  
`:wq 保存退出`

# 5、发送给另外两个虚拟机 #

scp -r /usr/local/kafka/ root@192.168.73.140:/usr/local/kafka/

敲完命令后输入密码就发送成功

scp -r /usr/local/kafka/ root@192.168.73.141:/usr/local/kafka/

敲完命令后输入密码就发送成功

`:wq 保存退出`  
第二台机器

# 实例id不可以重复
    broker.id=1
    # 配置kafka的host和port 
    # 格式 listeners=PLAINTEXT://当前主机ip:端口号
    listeners=PLAINTEXT://192.168.73.140:9093
    # kafka数据的存放目录
    log.dirs=/usr/local/kafka/kafka/logs
    # zookeeper集群的ip和端口，用英文逗号进行分隔
    zookeeper.connect=192.168.73.139:2181,192.168.73.140:2182,192.168.73.141:2183
    # 在配置文件中添加如下配置，表示允许删除topic
    delete.topic.enable=true

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 1]  
`:wq 保存退出`  
第三台机器

# 实例id不可以重复
    broker.id=2
    # 配置kafka的host和port 
    # 格式 listeners=PLAINTEXT://当前主机ip:端口号
    listeners=PLAINTEXT://192.168.73.141:9094
    # kafka数据的存放目录
    log.dirs=/usr/local/kafka/kafka/logs
    # zookeeper集群的ip和端口，用英文逗号进行分隔
    zookeeper.connect=192.168.73.139:2181,192.168.73.140:2182,192.168.73.141:2183
    # 在配置文件中添加如下配置，表示允许删除topic
    delete.topic.enable=true

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 1]  
`:wq 保存退出`

# 6、启动 #

首先 启动 zookeeper  
在启动 kafka

## 6.1 kafka启动命令 ##

cd /usr/local/kafka/kafka/bin

`./kafka-server-start.sh -daemon ../config/server.properties`

# 7、执行 #

## 7.1 创建主题 first ##

./kafka-topics.sh --create --zookeeper 192.168.73.139:2181 --replication-factor 2 --partitions 2 --topic first

## 7.2 启动发送者 ##

./kafka-console-producer.sh --broker-list 192.168.73.139:9092 --topic first

## 7.2 启动消费者 ##

./kafka-console-consumer.sh --bootstrap-server 192.168.73.139:9092 --from-beginning --topic first

`花开一千年,花落一千年,花叶永不见`

[jdk]: https://blog.csdn.net/weixin_43731532/article/details/112260464
[zookeeper]: https://blog.csdn.net/weixin_43731532/article/details/112304016
[vim]: https://blog.csdn.net/weixin_43731532/article/details/104484370
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70]: /images/20221119/69fdd5c6862c436ba09ce39fbd808fd3.png
[2021011209341639.png]: https://img-blog.csdnimg.cn/2021011209341639.png
[20210112093247301.png]: https://img-blog.csdnimg.cn/20210112093247301.png
[20210112093436227.png]: https://img-blog.csdnimg.cn/20210112093436227.png
[20210112093527487.png]: https://img-blog.csdnimg.cn/20210112093527487.png
[20210112093915227.png]: https://img-blog.csdnimg.cn/20210112093915227.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210112142406503.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210116175611134.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210116175523269.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzczMTUzMg==,size_16,color_FFFFFF,t_70