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

kafka生产者和消费者命令的使用

article 2024/11/27 19:22:24

kafka-console-producer.sh

生产数据

# 发送信息 指定topic即可
kafka-console-producer.sh \
--bootstrap-server bigdata01:9092 \
--topic topicA  # 主题

# 进程
29124 ConsoleProducer

 kafka-console-consumer.sh

消费数据

# 消费数据
kafka-console-consumer.sh \
--bootstrap-server bigdata01:9092 \
--topic topicA \ # 主题
--from-beginning \ # 从头开始
--group donghu2 # 组名

# 进程
28614 ConsoleConsumer


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

相关文章：

  • Jmeter测试工具的安装和使用，mac版本，jmeter版本5.2.1
  • K8s的水平自动扩容和缩容HPA
  • 【C++】读取数量不定的输入数据
  • 如何选择黑白相机和彩色相机
  • C++中的链式操作原理与应用(一)
  • 正则表达式灾难：重新认识“KISS原则”的意义
  • 深入解析下oracle date底层存储方式
  • 利用Java爬虫获取1688商品类目：技术解析与代码示例
  • python操作Elasticsearch
  • PHP md5函数 生成的字符串是多少位的
  • 一个开源轻量级的服务器资源监控平台，支持告警推送
  • 应用商店双弹窗“APP在向用户申请权限时未同步告知用户申请此权限的理由”驳回uni-app应用上线的解决方法
  • 从零开始学GeoServer源码（二）添加支持arcgis切片功能
  • 小程序-基于java+SpringBoot+Vue的网上花店微信小程序设计与实现
  • Android Toast信息定位分析介绍
  • 基于Matlab实现Gabo滤波器（源码）
  • java虚拟机——JVM中，内存的哪些区域被划分为线程私有、哪些区域是线程共享的
  • 从0开始深度学习（32）——循环神经网络的从零开始实现
  • 常用的数据结构
  • llama-factory 系列教程 (七)，Qwen2.5-7B-Instruct 模型微调与vllm部署详细流程实战
  • Springboot 整合 Java DL4J 构建自然语言处理之机器翻译系统
  • 实现一个可配置的TCP设备模拟器，支持交互和解析配置
  • Linux下环境基础开放工具
  • 林业产品推荐系统：Spring Boot解决方案
  • flink学习（7）——window
  • 基于SpringBoot+Vue的智慧社区网站-无偿分享 (附源码+LW+调试)