kafka-2.12使用记录

超、凢脫俗 2024-03-23 20:38 60阅读 0赞

## kafka-2.12使用记录 ##

### 安装kafka 2.12版本 ###

#### 下载安装包 ####

根据你的系统下载rpm /deb /zip包等等, 这里我使用的是rpm包
    安装命令 rpm -ivh kafka-2.12-1.nfs.x86_64.rpm

#### 启动内置Zookeeper ####

以下命令要写在同一行上

/opt/kafka-2.12/bin/zookeeper-server-start.sh 
    /opt/kafka-2.12/config/zookeeper.properties

![在这里插入图片描述][e1709625d194443f9b2b09af72ee6072.png_pic_center]

#### 启动kafka服务器 ####

以下命令要写在同一行上

/opt/kafka-2.12/bin/kafka-server-start.sh
    /opt/kafka-2.12/config/server.properties

![在这里插入图片描述][caee3e459f574d8e83a3f2713172f66a.png_pic_center]

### 使用kafka ###

#### 创建和查看topic ####

创建一个单 partition分区，单 replication副本 的叫 topic2023 的主题

/opt/kafka-2.12/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1  --partitions 1 --topic topic2023

查看topic列表

/opt/kafka-2.12/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

![在这里插入图片描述][0192d9c8f2f14841b850057c278b5f38.png_pic_center]

#### 创建1个消息生产者 ####

命令输入完后，可以继续输入 多行要发送的消息内容

/opt/kafka-2.12/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic2023

![在这里插入图片描述][cc973a68a94e4eaaad8d0b5afe75c632.png_pic_center]

#### 创建1个消息消费者 ####

命令输入完成后回车，可以看到控制台显示出订阅到的消息内容

/opt/kafka-2.12/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic2023 --from-beginning

![在这里插入图片描述][4921e706e7ed4f9794ad9738e196c823.png_pic_center]

### 配置kafka允许外网访问 ###

需要进入config目录，修改server.properties文件里的配置

修改listeners配置项

listeners指定kafka监听的本地地址和端口，这里配置为0.0.0.0:9092表示监听所有网络接口

listeners = PLAINTEXT://0.0.0.0:9092

修改advertised.listeners配置项

advertised.listeners是用于向客户端公布你的kafka访问地址，需要配置为你的机器的外部IP和端口

advertised.listeners=PLAINTEXT://10.1.5.212:9092

![在这里插入图片描述][500530680bbe4477a810b8790aa22a40.png_pic_center]

### 测试zookeeper联通性 ###

可以使用prettyZoo客户端工具测试访问zk服务器

![在这里插入图片描述][90815849d1734a25b38c1c7dad5940c5.png_pic_center]

### 使用kafkaUI-lite在线浏览和测试kafka ###

#### 什么是kafkaUI-lite ####

kafka-ui-lite是一个开源的kafka监控项目，可以在gitee下载.
    提供了对kafka 、zookeeper 、redis的监控和管理功能，
    支持在线浏览和管理kafka的 topic主题/kafka集群/group分组
    支持在线发送kafka消息

#### 使用kafkaUI-lite查看topic ####

![在这里插入图片描述][197eb9fec90547feba8dec6109ea0e8c.png_pic_center]

#### 使用kafkaUI-lite创建topic ####

![在这里插入图片描述][6fdef8dfe4224eadb5ae5dc421859ec3.png_pic_center]

#### 使用kafkaUI-lite发送消息 ####

![在这里插入图片描述][c0c314b5ada34fc2a1a2544a745f15b6.png_pic_center]

#### 使用kafkaUI-lite查看zookeeper信息 ####

![在这里插入图片描述][d6856dafb0044c0a97a2f0e47218a6ec.png_pic_center]

[e1709625d194443f9b2b09af72ee6072.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/9820b3ae77294e0fbc933c8e184af4fe.png
[caee3e459f574d8e83a3f2713172f66a.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/b296b45b73db41198a6f6e0eb2e51657.png
[0192d9c8f2f14841b850057c278b5f38.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/444d986304ba4bfa8b8073ad5d8f8bfb.png
[cc973a68a94e4eaaad8d0b5afe75c632.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/1347cc3d4250451f9404cdbeed3f3f12.png
[4921e706e7ed4f9794ad9738e196c823.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/c30630724c504234b35713bb3c69b67c.png
[500530680bbe4477a810b8790aa22a40.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/59d69dba17754fba8d3d114ca8acfc89.png
[90815849d1734a25b38c1c7dad5940c5.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/45242f13da5f4d18b6c727be2b01606a.png
[197eb9fec90547feba8dec6109ea0e8c.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/714295bd1cb6451c9e6fdcecd369d702.png
[6fdef8dfe4224eadb5ae5dc421859ec3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/c5cab8b035b649c59027c13d63112847.png
[c0c314b5ada34fc2a1a2544a745f15b6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/69940968779548b1b56af3d3d02c7f3d.png
[d6856dafb0044c0a97a2f0e47218a6ec.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/a97c015080ba494fb1c8698c5dabb144.png