Kafka一些常用的命令行操作【包含主题命令、生产者和消费者命令】

server/2024/11/17 18:52:56/

文章目录

    • 1、主题命令
    • 2、生产者命令行操作
    • 3、消费者命令行操作


1、主题命令

[图片]

查看当前服务器中的所有 topic:

kafka-topics.sh --bootstrap-server node01:9092 --list 

创建topic:

kafka-topics.sh --bootstrap-server node01:9092 --create --topic topicB --partitions 1 --replication-factor 3

查看主题的详情 :

kafka-topics.sh --bootstrap-server node01:9092 --describe --topic topicB 

2、生产者命令行操作

在这里插入图片描述

向主题发送消息:

kafka-console-producer.sh --bootstrap-server node01:9092 --topic topicB

3、消费者命令行操作

在这里插入图片描述
在这里插入图片描述

接收主题最新消息:

kafka-console-consumer.sh --bootstrap-server node01:9092 --topic topicB

接收主题所有消息(包括历史消息):

kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic topicB

http://www.ppmy.cn/server/142712.html

相关文章

一文3000字从0到1带你进行Mock测试(建议收藏)

​什么是mock? ​mock测试是以可控的方式模拟真实的对象行为。程序员通常创造模拟对象来测试对象本身该具备的行为,很类似汽车设计者使用碰撞测试假人来模拟车辆碰撞中人的动态行为 为什么要使用Mock? 之所以使用mock测试,是因…

单片机 串口实验 实验五

实验五 串口实验 一、实验目的 1、掌握MCS-51单片机串口通信的原理。 2、掌握MCS-51单片机串口通信程序的设计方法及其过程。 3、掌握MCS-51单片机串口通信的电路应用。 二、实验任务 两片单片机分别接一个按键和两个数码管,通过串口通信,实现单…

【大数据学习 | HBASE高级】hbase的API操作

首先引入hbase的依赖 <dependencies><dependency><groupId>org.apache.hbase</groupId><artifactId>hbase-server</artifactId><version>2.4.13</version></dependency><dependency><groupId>org.slf4j<…

Java重点---值传递和引用传递

目录 ⭐Java中只有值传递&#xff0c;没有引用传递&#xff1b;C里才有引用传递⭐ ⭐对象初始化顺序&#xff08;对象的每个部位在内存中申请空间以及赋值的顺序&#xff09; ⭐代码块的优先级高于构造方法&#xff0c;而代码块&#xff08;方法块&#xff09;之间的优先级相…

算法训练(leetcode)二刷第二十七天 | *56. 合并区间、*738. 单调递增的数字、*968. 监控二叉树

刷题记录 *56. 合并区间*738. 单调递增的数字*968. 监控二叉树 *56. 合并区间 leetcode题目地址 重叠区间&#xff0c;若前一个区间的右边界大于等于当前区间的左边界&#xff0c;则有重叠&#xff0c;合并两个区间。 时间复杂度&#xff1a; O ( n l o g n ) O(nlogn) O(n…

2019计挑赛c语言

1.下列选项中,说法正确的是(D)。 a.函数的形参可以是常量、变量或表达式 实参可以是任何类型(可以是常量,变量或表达式),但是形参却不能是表达式 形参不能是表达式 b.函数返回值的类型是由return语句中表达式类型决定 函数返回值的类型是由函数定义时指定的类型决定的,…

工业相机选取

1.相机分类&#xff1a; 1.1 在相机曝光方式中&#xff0c;全局曝光和卷帘曝光是两种主流技术。CCD相机通常采用全局曝光方式&#xff0c;而CMOS相机则可能采用卷帘曝光。 面阵相机与全局曝光关联与区别 关联&#xff1a;面阵相机可以使用全局曝光作为曝光方式&#xff0c;但…

github 以及 huggingface下载模型和数据

runningcheese/MirrorSite: 镜像网站合集 (github.com) huggingface 下载模型和数据使用snapshot_download的方法 不会修改HuggingFace模型下载默认缓存路径&#xff1f;一篇教会你!_huggingface默认下载路径-CSDN博客 下载模型 使用snapshot_download 使用snapshot_down…