当前位置： 首页 > article >正文

kafka操作

article 2025/2/24 21:13:54

kafka 操作

基本操作

# 列出所有的主题 --bootstrap-server 是必选参数
./kafka-topics.sh --list --bootstrap-server localhost:9092

# 创建主题
./kafka-topics.sh --create --topic hello --bootstrap-server localhost:9092

# 删除主题
./kafka-topics.sh --delete --topic hello --bootstrap-server localhost:9092

# 显示主题详细信息
./kafka-topics.sh --describe --topic hello --bootstrap-server localhost:9092

# 修改主题信息
./kafka-topics.sh --alter --topic hello --partitions 5 --bootstrap-server localhost:9092

写入操作

# 写入操作
./kafka-console-producer.sh --topic hello --bootstrap-server localhost:9092

# 每一次换行是一个事件 Event
# 使用Ctrl+C退出，停止发送事件Event到主题 Topic

读取操作

# 读取操作
./kafka-console-consumer.sh --topic hello --from-beginning --bootstrap-server localhost:9092

# 使用Ctrl+C停止消费者客户端

事件Events是持久存储在Kafka中的，所以它们可以被任意多次读取


http://www.kler.cn/a/281406.html

相关文章：

  • 深度学习与神经网络戴做讲解
  • Java大文件下载方案(vue+饿了么)：分片下载、断点续载!
  • Redis高级----主从、哨兵、分片、脑裂原理
  • el-select如何自定义宽度
  • 以阅读为翼,将英语学习融入青少年生活日常
  • 数据仓库系列4-什么是维度建模,它与关系型建模有什么区别
  • 0816，特殊数据成员/成员函数，对象组织，delete/new，单例模式
  • 最大公约数（欧几里得算法）
  • 【MySQL 11】索引 (带思维导图)
  • HarmonyOs如何获取rawfile目录下的所有文件列表
  • 【前端开发】国际化开发工具i18n的使用教程
  • redis | 认识非关系数据库Redis的字符串数据类型及过期时间expire的作用
  • Python画笔案例-019 绘制阴影丫字
  • nginx 负载均衡详解与实现方法案例
  • 16002.orin nano平台 linux gpio 学习记录
  • UniApp微信小程序登录实战指南
  • 掌握CSS的@import：跨文件样式的艺术
  • 【设计模式】组合模式和(宏)命令模式
  • LeetCode 热题100-36 二叉树的中序遍历
  • 采购订单抬头屏幕增加字段的增强实施步骤 (SMOD:MM06E005) ＜转载＞