Kafka模拟实现（用于自我测试环境）

1.模拟实验

[root@yws85 ~]# cd /opt/software/kafka/
[root@yws85 kafka]# bin/kafka-topics.sh \
> --create \
> --zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
> --replication-factor 3 \
> --partitions 3 \
> --topic g5
Created topic "g5".
[root@yws85 kafka]# ll bin
kafka-console-producer.sh
kafka-console-consumer.sh

不知道如何使用得话

[root@yws85 kafka]# cd bin
[root@yws85 bin]#./kafka-console-producer.sh

就可以看到使用

模拟生产者

[root@yws85 kafka]#bin/kafka-console-producer.sh \
--broker-list 192.168.0.85:9092,192.168.0.86:9092,192.168.0.87:9092 \
--topic g5

模拟消费者

[root@yws85 kafka]#bin/kafka-console-consumer.sh \
--zookeeper 192.168.0.85:2181,192.168.0.86:2181,192.168.0.87:2181/kafka \
--topic g5 \
--from-beginning

注意2者的区别
这时在生产者输入消息，消费者就会得到，
在未来当中，你不知道你部署的kafka是否ok，自己就需要模拟一下、
一个是发数据kafka-console-producer.sh，一个是消费数据kafka-console-consumer.sh。

Kafka模拟实现（用于自我测试环境）相关推荐

gor 测试环境搭建
gor 为go语言编写的http转发程序,可用于搭建测试环境. 用法示例: 1.输出请求 sudo ./gor --input-raw :80 --output-stdout 2.转发请求 ./gor ...
用于情绪测试的软件,第七章情感心理自我测试心理测评软件
原标题:第七章情感心理自我测试心理测评软件处于花季的少男少女们,想知道你的情感心理是否健康吗?那么,不妨跨入情感心理自我测试的门槛,逐一为你解决. 世上连两片一模一样的树叶都找不到,更何况是不同的 ...
App上架时，华为应用市场提示:在测试环境：Wi-Fi联网、EMUI11.0 ( P40），软件存在闪退。如何模拟EMUI11.0 ( P40）
请问如何模拟EMUI11.0 ( P40)环境,用夜神等模拟器没有复现,环境也不是p40
FlexRay汽车通信总线介绍及测试环境
FlexRay汽车通信总线介绍及测试环境原文链接:http://www.ulantec.cn/a/xinwen/xingyezixun/8.html 综述 FlexRay通信总线是由多个汽车制造商和 ...
手把手教你搭建智能合约测试环境、开发、编译、部署以及如何通过JS调用合约方法
链客,专为开发者而生,有问必答! 此文章来自链客区块链技术问答社区,未经允许拒绝转载. 学习目标了解智能合约简单环境搭建能够利用solidity编写Hello World合约合约部署和合约互 ...
区域链实践第一步——区域链测试环境搭建
区域链光速发展,在许多人的期许下,已经成为了互联网下一个革新点.区块链会成就的未来价值互联网,是新时代的基石. IBM中国研究院开发的超能云(SuperVessel)平台提供了给区块链爱好者.开发者的 ...
network setup service启动后自动停止_一个简单的测试环境下的自动化部署方案
笔者是公司是一个分前后端开发的公司.而笔者是一个普通的后端开发工程师.在和前端工程师协同开发时,为了给前端工程师提供接口,往往要将写好的代码交付并部署到测试环境.因而这导致笔者经常需要打包项目更新到测 ...
qt5.9.0调试如何查看变量的值_从0开发3D引擎（四）：搭建测试环境
大家好,本文介绍了3D引擎的测试方法,搭建了本地的测试环境. 上一篇博文 wonder-yyc:从0开发3D引擎(三):搭建开发环境zhuanlan.zhihu.com 下一篇博文 wonder-y ...
java实现沙箱测试环境支付宝支付（demo）和整合微信支付和支付宝支付到springmvc+spring+mybatis环境全过程（支付宝和微信支付）
一.支付宝测试环境代码测试 1.下载电脑网站的官方demo: 下载地址:https://docs.open.alipay.com/270/106291/ 2.下载解压导入eclipse readme. ...

Kafka模拟实现（用于自我测试环境）

1.模拟实验

模拟生产者

模拟消费者

Kafka模拟实现（用于自我测试环境）相关推荐

最新文章

热门文章