kafka查询命令---Linux

摘要:
Kafka版本:Kafka_2.12-2.1.1kafka _端口默认为9092,zk_端口默认值2181查看topicbin/Kafka主题。sh--zookeperzk_ip:zk_Port--list查看groupbin/kafka用户组。sh--引导服务器kafka-ip:kafka_Port--list查看主题下的基础

kafka版本:kafka_2.12-2.1.1

kafka_port默认9092,zk_port默认2181

查看topic
bin/kafka-topics.sh --zookeeper zk_ip:zk_port --list

查看group
bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --list

查看topic下group的消费情况
bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --group group_name --describe

手动设置offset

停止consumer后,设置group=3,topic=test的offset为1524510

bin/kafka-consumer-groups.sh --bootstrap-server kafka_ip:kafka_port --group 3 --topic  test --execute --reset-offsets --to-offset 1524510

免责声明:文章转载自《kafka查询命令---Linux》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇海思MPP视频处理平台流程简介WPF LiveChart 图表详解下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

Windows和Linux下查看Apache、MySQL、PHP版本

# Windows查看Apache版本: 使用命令:httpd -v # Linux查看Apache版本: 使用命令:apachectl -v # Windows查看MySQL版本: 使用命令:mysql --version # Linux查看MySQL版本: 使用命令:mysql -V # Windows查看PHP版本: 使用命令:php -v...

(转) Linux命令学习手册-arp命令

arp 原文:http://blog.chinaunix.net/uid-9525959-id-3318814.html [功能] 管理系统的arp缓存。 [描述] 用来管理系统的arp缓存,常用的命令包括: arp:显示所有的表项。 arp-daddress:删除一个arp表项。 arp-s address hw_addr:设置一个arp表项。 常用参数...

从点一个灯开始学写Linux字符设备驱动

关注、星标嵌入式客栈,精彩及时送达 [导读] 前一篇文章,介绍了如何将一个hello word模块编译进内核或者编译为动态加载内核模块,本篇来介绍一下如何利用Linux驱动模型来完成一个LED灯设备驱动。点一个灯有什么好谈呢?况且Linux下有专门的leds驱动子系统。 点灯有啥好聊呢? 在很多嵌入式系统里,有可能需要实现数字开关量输出,比如: L...

工作问题解决

1.init  测试设计 选项 -e  telinit   -e init 测试选项 man 手册 正式。 2. 8.2 Linux源代码的目录结构8.2.1 Linux目录结构Linux的源代码全部在一个目录下,这里有很多文件夹,包含不同功能的源代码:├—init 内核初始化代码 ├—kernel 内核核心部分:进程,定时,程序执行,信号,模块... ├...

linux上部署vue项目

1、是将dist文件夹下的内容不知道目录中,而不是dist目录 2、下面的/var/www目录可以自定义 1、需要改四个地方:listen server_name location中的root location中的proxy_pass listen:监听的端口,为vue的端口 server_name:服务器的名称,一般服务器的ip(写了地址可能有警告,不...

linux编程头文件所在路径的问题

一、问题引入 1、头文件与库       当我们在PC主机linux环境下(如ubuntu),编写linux应用程序,然后利用gcc来编译。在源代码的开始位置会写入头文件,那是因为我们使用了系统提供的库函数,例如printf、open、read、write等等。我们会写入类似的内容: #include <stdio.h> #include &...