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

kafka启动消费者和生产者(单节点)

1.启动zookeeper
zkServer.sh start

2.启动kafka

(进入kafka安装目录):bin/kafka-server-start.sh config/server.properties

3.复制出节点2查看kafka是否启动 jps
在这里插入图片描述

4.用topics创建一个名为"test"的主题

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

在这里插入图片描述

5.启动生产者

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

输入数据
在这里插入图片描述

7.复制节点3 启动消费者

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

可以看到生产者的数据

在这里插入图片描述

相关文章:

  • sublime通过sftp远程连接linux
  • pyecharts的render函数无法运行,无法生成html文件
  • JavaDoc生成文档
  • JAVA用户交互Scanner
  • Java if选择结构
  • Java switch多选结构
  • While循环结构
  • For循环结构
  • Java方法的定义和调用
  • Java方法的重载
  • Java可变参数
  • Java递归
  • JAVA实现计算器
  • Java方法的调用(值传递和引用传递)
  • Java对象和类的关系与创建
  • @jsonView过滤属性
  • 《Javascript数据结构和算法》笔记-「字典和散列表」
  • 【译】理解JavaScript:new 关键字
  • 3.7、@ResponseBody 和 @RestController
  • canvas 高仿 Apple Watch 表盘
  • express.js的介绍及使用
  • Git的一些常用操作
  • hadoop入门学习教程--DKHadoop完整安装步骤
  • HomeBrew常规使用教程
  • JavaScript中的对象个人分享
  • use Google search engine
  • vue--为什么data属性必须是一个函数
  • yii2权限控制rbac之rule详细讲解
  • 干货 | 以太坊Mist负责人教你建立无服务器应用
  • 回顾2016
  • 前端临床手札——文件上传
  • 深度解析利用ES6进行Promise封装总结
  • 正则学习笔记
  • 【云吞铺子】性能抖动剖析(二)
  • ​力扣解法汇总1802. 有界数组中指定下标处的最大值
  • #git 撤消对文件的更改
  • #Z0458. 树的中心2
  • (rabbitmq的高级特性)消息可靠性
  • (webRTC、RecordRTC):navigator.mediaDevices undefined
  • (第61天)多租户架构(CDB/PDB)
  • (附源码)springboot车辆管理系统 毕业设计 031034
  • (附源码)springboot工单管理系统 毕业设计 964158
  • (黑马C++)L06 重载与继承
  • (提供数据集下载)基于大语言模型LangChain与ChatGLM3-6B本地知识库调优:数据集优化、参数调整、Prompt提示词优化实战
  • (一)使用IDEA创建Maven项目和Maven使用入门(配图详解)
  • (转)编辑寄语:因为爱心,所以美丽
  • (转)视频码率,帧率和分辨率的联系与区别
  • (转载)CentOS查看系统信息|CentOS查看命令
  • .bat批处理(九):替换带有等号=的字符串的子串
  • .net 4.0发布后不能正常显示图片问题
  • .NET CF命令行调试器MDbg入门(四) Attaching to Processes
  • .NET gRPC 和RESTful简单对比
  • .NET HttpWebRequest、WebClient、HttpClient
  • .net 打包工具_pyinstaller打包的exe太大?你需要站在巨人的肩膀上-VC++才是王道
  • .net网站发布-允许更新此预编译站点