Kafka 常见命令行 Version 2.1.0
Kafka Command
Version 2.1.0
kafka-consumer-groups.sh
kafka group
消费者组：list
$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --list
trajectoryGroup
myGroup
消费者组：state
$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --stateCOORDINATOR (ID) ASSIGNMENT-STRATEGY STATE #MEMBERS
hadoop1:59092 (0) range Stable 4
消费者组：describe
查看消息堆积
$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describeTOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
xxx_trajectory 0 143693805 143693905 100 consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1
xxx_trajectory 1 137186261 137186348 87 consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1
消费者组：members
$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --membersCONSUMER-ID HOST CLIENT-ID #PARTITIONS
consumer-1-2de6119e-fc4f-41a6-baa1-a702665d9c6f /59.202.28.237 consumer-1 3
consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1 3
消费者组：members verbose
$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --members --verboseCONSUMER-ID HOST CLIENT-ID #PARTITIONS ASSIGNMENT
consumer-1-2de6119e-fc4f-41a6-baa1-a702665d9c6f /59.202.28.237 consumer-1 3 xxx_trajectory(3,4,5)
consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1 3 xxx_trajectory(0,1,2)
kafka topic
主题：list
$ ./kafka-topics.sh --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181/kafka_2.11-2.1.0 --list
__consumer_offsets
xxx_trajectory
主题：describe
查看主题分区信息、副本信息、同步副本信息
./kafka-topics.sh --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181/kafka_2.11-2.1.0 --topic xxx_trajectory --describe
Topic:xxx_trajectory PartitionCount:6 ReplicationFactor:2 Configs:Topic: xxx_trajectory Partition: 0 Leader: 2 Replicas: 2,1 Isr: 1,2Topic: xxx_trajectory Partition: 1 Leader: 2 Replicas: 0,2 Isr: 2,0Topic: xxx_trajectory Partition: 2 Leader: 1 Replicas: 1,0 Isr: 1,0Topic: xxx_trajectory Partition: 3 Leader: 2 Replicas: 2,0 Isr: 2,0Topic: xxx_trajectory Partition: 4 Leader: 1 Replicas: 0,1 Isr: 1,0Topic: xxx_trajectory Partition: 5 Leader: 1 Replicas: 1,2 Isr: 1,2
kafka console consumer
控制台消费者：
控制台命令行消费者：消费主题消息
$ ./kafka-console-consumer.sh --zookeeper hadoop4:59092,hadoop5:59092,hadoop6:59092 --topic xxx_trajectory --describe
Kafka 常见命令行 Version 2.1.0相关推荐
- 曙光服务器bios开启虚拟化支持,中科曙光虚拟化培训教程汇总：3.1 使用针对ESXi的常见LSI 命令行管理工具 v1.0.pdf...
使用针对ESXi的常见LSI命令行管理 工具 v1.0 版本 发布日期 修改人 修改原因 1.0 2017.04.11 梁旭 首次发布 1 目录 一.vib 工具包安装 3 1．安装针对LSI 220 ...
- kafka _命令行操作
kafka _命令行操作 #启动zk zkServer.start #启动kafka kafka-server-start.sh -daemon /opt/kafka/config/server.pr ...
- 很有用的东西，可以修复MBR引导区，在windows命令行下mbrfix /drives 0 fixmbr就可以了
很有用的东西,可以修复MBR引导区,在windows命令行下mbrfix /drives 0 fixmbr就可以了
- JVM常见命令行及图形工具
目录 JDK 命令行工具 jps:查看所有 Java 进程 jinfo:实时地查看和调整虚拟机各项参数 jstat:监视虚拟机各种运行状态信息 jmap:生成堆转储快照 jhat:分析 heapdum ...
- Kafka常用命令行命令
文章目录 Kafka常用命令 kafka的基本操作(命令行操作) 1.启动集群: 2.查看当前服务器中的所有topic(在kafka目录下) 3.创建主题topic(在kafka目录下) 4.删除to ...
- kafka常见命令集锦
目录 目标 相关概念 环境 启动zookeeper和kafka节点 命令集锦 查看kafka节点数量 查看所有消费者组 查看消费者组详情 创建主题 扩容分区 查看主题详情 查看所有主题 删除主题 发送 ...
- SecureCRT常见命令行
Redis的常规操作 1 目录操作 mkdir a ;(新建文件夹) mkdir -p a/b;(新建多及目录文件夹) Rmdir a (a只能是空目录) Rmdir -p a (a可以是多级目录) ...
- android安装命令行工具下载,Command line tools下载-Command line tools(命令行工具)下载 v1.0官方版--pc6下载站...
Commandlinetools命令行工具,如果你不需要AndroidStudio,你可以使用基本Android命令行工具,你可以使用包含的sdkmanager来下载其他SDK包,这些工具都包含在An ...
- Linux常见命令行
一.Linux中的一些知识: 1.路径分割符尾"/' 2.如果要求不断输入,想终止输入,Ctrl+D 3.如果想直接终止命令, Ctrl+C 4.清屏,输入clear或者Ctrl+L 二.L ...
最新文章
- 获取当前脚本目录路径问题汇总
- 你所需要的java基础篇深入解析大汇总
- 计算机分组教学,中职计算机教学分组协作式学习论文
- DCMTK：测试图像像素模块功能
- WeakHashMap垃圾回收原理
- java写入单个字符_将2个字符写入单个Java char
- JavaScript中的原型继承原理
- sublime中编译的sass如何改变css输出风格？【这里有答案】
- python原创第十四篇~判断，循环实战训练+答案
- Swift学习笔记 In-out形参
- 【本人秃顶程序员】SpringMVC工作原理详解
- 校招行测笔试-言语理解与表达
- 库存管理一般用什么软件比较好？
- android ogg 播放器,android如何让自己开发的播放器成为可供文件选择的播放器
- 收藏 | 湖南省各地教师公务员等实际工资爆料
- 初中英语语法(003)-be动词和一般动词的一般过去式
- 【最大流，最大匹配，最大独立集】2018.6.18 【2018提高组】模拟C组 T3 沙耶的玩偶
- 英语背单词软件需求分析
- php皮肤程序,2020修复升级版PHP全新皮肤界面点赞任务系统平台源码运营版,仿众人帮蚂蚁帮扶牛帮...
- linux 原型软件,7款免费原型设计工具，总有一款是你的菜！