053 kafka自带的生产者与消费者测试
2024-08-28 23:19:01
1.命令
2.启动生产者
bin/kafka-console-producer.sh --topic beifeng --broker-list linux-hadoop01.ibeifeng.com:9092,linux-hadoop01.ibeifeng.com:9093,linux-hadoop01.ibeifeng.com:9094.linux-hadoop01.ibeifeng.com:9095
3.启动消费者
bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibeifeng.com:2181/kafka
4.在生成者的控制台上添加数据
5.消费者接收到的数据
最新文章
- 发现一个百度的密码。。。记最近一段时间的php感想
- java 线程的几种状态
- ssh2框架搭建
- python 解析 xml
- 【转】浅析Windows编程的剪贴板
- Mahout
- [poj 1039]Pipes[线段相交求交点]
- CentOS7.0安装Nginx
- drawpoly(）函数的用法
- 恶补web之八:jQuery(1)
- [Union]C++中Union学习笔记
- vue 使用微信JSSDK，在IOS端会授权出错
- SpringCloud Hystrix
- zabbix的自动发现、自定义添加监控项目、配置邮件告警
- UE4官方行为树快速入门文档解析和修改
- Tomcat安全配置与性能优化
- 转载：QTableView中嵌入可视化组件
- C#各种结束进程的方法详细介绍
- c语言数组拷贝
- webpy 调试