Kafka use zkCli.sh to check topic offset on linux

> ./zkCli.sh -server zk1host:port,zk2host:port,zk3host:port

>help

ZooKeeper -server host:port cmd args
stat path [watch]
set path data [version]
ls path [watch]
delquota [-n|-b] path
ls2 path [watch]
setAcl path acl
setquota -n|-b val path
history
redo cmdno
printwatches on|off
delete path [version]
sync path
listquota path
rmr path
get path [watch]
create [-s] [-e] path data acl
addauth scheme auth
quit
getAcl path
close
connect host:port

原文地址:https://www.cnblogs.com/yjyyjy/p/10678613.html

时间: 2024-08-19 13:22:44

Kafka use zkCli.sh to check topic offset on linux的相关文章

关于kafka更改消费者对应分组下的offset值

kafka的offset保存位置分为两种情况 0.9.0.0版本之前默认保存在zookeeper当中 0.9.0.0版本之后保存在broker对应的topic当中 1.如何辨别你启用的consumer的offset保存位置进入zookeeper的命令行当中 zkCli.sh localhost:2181 用 ls / 查看目录如果你在代码中定义的group id 没有在 /consumers 这个文件夹中,代表offset保存在broker的topic中前提是consumer确实已经创建并启动如

Kafka管理与监控——彻底删除topic

一.配置 server.properties 设置 delete.topic.enable=true 如果没有设置 delete.topic.enable=true,则调用kafka 的delete命令无法真正将topic删除,而是显示(marked for deletion) 二.停止消费 如果需要被删除topic 此时正在被程序 produce和consume,则这些生产和消费程序需要停止. 因为如果有程序正在生产或者消费该topic,则该topic的offset信息一致会在broker更新

kafka源码走读-controller (创建topic过程)

晚上刚刚被媳妇骂,难过之余,还是要坚持继续写一篇kafka源码走读的博客,心情难过,原谅我开头发下牢骚... 源码版本依然是0.10.2.1,我们都知道,kafka在0.8版本前没有提供Partition的Replication机制,一旦Broker宕机,其上的所有Partition就都无法提供服务,而Partition又没有备份数据,数据的可用性就大大降低了,所以0.8后提供了Replication机制来保证Broker的failover,而controller则是实现副本机制的核心. con

kafka集群扩容后的topic分区迁移

kafka集群扩容后的topic分区迁移 ./bin/kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181  --alter --topic dftt --partitions 4 kafka集群扩容后,新的broker上面不会数据进入这些节点,也就是说,这些节点是空闲的:它只有在创建新的topic时才会参与工作.除非将已有的partition迁移到新的服务器上面:所以需要将一些topic的分区迁移到新的broker上. kaf

【Apache ZooKeeper】命令行zkCli.sh使用指南

ZooKeeper命令行 原文                   http://blog.csdn.net/ganglia/article/details/11606807 ZooKeeper客户端有C语言和Java两个版本. ZooKeeper的命令在/usr/lib/zookeeper/bin文件夹下. 运行Java版本的客户端使用bash zkCli.sh -server IP:port ,运行C语言版本的使用./cli_mt IP:port,下面介绍Java版本的,C语言版差不多. 查

分布式服务管理框架-Zookeeper客户端zkCli.sh使用详解

原文链接:http://blog.csdn.net/xyang81/article/details/53053642 在学习zookeeper(下面简称zk)客户端之前,有必要先了解一下zk的数据模型.zk维护着一个逻辑上的树形层次结构,树中的节点称为znode,和Linux系统的文件系统结构非常相似,如下图所示: 这种数据结构有如下特点: 1> 每个znode都有唯一路径标识,最顶层的znode为/,比如p_2这个znode的路径标识为/app1/p_2,znode只支持绝对路径,不支持相对路

zookeepeer使用zkCli.sh命令

一.连接服务器端 1 [[email protected] zookeepeer]# ./bin/zkCli.sh -server 192.168.116.144:2181 2 Connecting to 192.168.116.144:2181 3 2018-01-11 06:55:04,157 [myid:] - INFO [main:[email protected]100] - Client environment:zookeeper.version=3.4.11-37e277162d5

./zkcli.sh: line 13: unzip: command not found

异常信息: Error: Could not find or load main class org.apache.solr.cloud.ZkCLI 异常原因: 想执行 solrhome 配置文件上传命令: ./zkcli.sh -zkhost 192.168.0.1:218 -cmd upconfig -confdir /usr/local/solr-cloud/solrhome01/collection1/conf/ -confname myconf 但是系统没有安装 unzip 和 zip

Zookeeper详解(四):Zookeeper中的zkCli.sh客户端使用

最好配置上环境变量 连接操作: zkCli.sh -timeout 1000 -r -server 127.0.0.1 # -timeout 设置客户端和服务器之间的超时时长,单位毫秒 # -r 只读模式,不加就是读写模式 # -server IP:PORT 要连接的服务器 查询操作: ls /   # 查看指定路径下的节点 stat PATH # 查看指定节点的状态信息 get PATH # 获取指定节点的数据,它会包括状态信息 原文地址:http://blog.51cto.com/littl