当前位置: 首页 > news >正文

kafka-- 安装kafka manager及简单使用

一 、安装kafka manager 管控台:

# 安装kafka manager 管控台:
## 上传
cd /usr/local/software
## 解压
unzip kafka-manager-2.0.0.2.zip -d  /usr/local/
cd /usr/local/kafka-manager-2.0.0.2/conf
vim /usr/local/kafka-manager-2.0.0.2/conf/application.conf
###修改内容
kafka-manager.zkhosts="172.16.144.133:2181,172.16.144.134:2181,172.16.144.135:2181"
### 启动kafka控制台
/usr/local/kafka-manager-2.0.0.2/bin/kafka-manager &
# 浏览器访问控制 默认端口号是9000
http://172.16.144.133:9000

二、测试 添加cluster

在这里插入图片描述

然后save 一下

成功标志

在这里插入图片描述

三、测试 kafka简单的集群命令

## 7集群验证:
## 7.1通过控制台创建了个topic为"test" 2个分区1个副本

1、创建topic

在这里插入图片描述

在这里插入图片描述

cd /usr/local/kafka_2.12/kafka-logs;ls;

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

cd test-0

在这里插入图片描述

2、消费发送与接收验证

## 7.2消费发送与接收验证
cd /usr/local/kafka_2.12/bin
##启动发送消息的脚本
## --broker-list 192.168.11.221 指的是kafka broker的地址列表
## --topic test 指的是把消息发送到test主题kafka-console-producer.sh --broker-list 172.16.144.133:9092 --topic test##启动接收消息的脚本
kafka-console-consumer.sh --bootstrap-server  172.16.144.133:9092 --topic test

生产者发送123

在这里插入图片描述

消费者发送123

在这里插入图片描述

http://www.lryc.cn/news/155984.html

相关文章:

  • 深圳-海岸城购物中心数据分析
  • vue3 + elementplus Cannot read properties of null (reading ‘isCE‘)
  • 易云维®医院后勤管理系统软件利用物联网智能网关帮助实现医院设备实现智能化、信息化管理
  • c# 定期重启程序操作
  • ps beta 2.5的妙用
  • IDEA无效发行版本17
  • Ubuntu22.04安装ROS
  • Linux 学习笔记(2)—— 关于文件和目录
  • [重要] 如何在桌面上生成一个指定网址的快捷方式
  • PyQt和Qt的其他绑定(如PySide)相比有什么优势和劣势?
  • 4K三路虚拟情景实训教学系统VR4300:实现“微课录制+课堂实训”双教学需求
  • python逆向还原dnspy反编译的C#算法
  • 数学建模--最短路径算法的Python实现
  • webpack学习(一)基本配置
  • Oracle 遍历变量游标
  • C++11新特性① | C++11 常用关键字实战详解
  • VUE3学习小记(2)- ref 与 reactive
  • 基于单片机的万年历温度无线传输控制系统系统
  • ElementUI浅尝辄止19:Badge 标记
  • nginx两台负载均衡服务器之间使用keepalived实现高可用
  • 如何将Express项目部署到Vercel
  • Java作业3
  • ARM编程模型-寄存器组
  • C++ string
  • 百亿级访问量,如何做缓存架构设计
  • (数字图像处理MATLAB+Python)第十一章图像描述与分析-第三、四节:几何表述和形状描述
  • 20230901工作心得:IDEA列操作lambda表达式加强版用法
  • macOS Sonoma 14beta 7(23A5337a)更新发布,附黑/白苹果系统镜像
  • QT基础教程之九Qt文件系统
  • OpenCV(十八):图像直方图