如何获取kafka某topic的Logsize?

2015年12月10日 - logSize Lag Owner console-consumer-11758 my-replicated-topic 0 3715607 ...kafka 的 api 提供了 getoffsetbefore 这个接口, 可以获取到最新的offs...

如何获取kafka某topic的Logsize基于0.8.0版本。##查看topic分布情况kafka-list-topic.shbin/kafka-list-topic.sh --zookeeper 192.168.197.170:2181,192...

2016年6月23日 - KafkaHelper { /** * 获取kafka logSize * @param host * @param port * @param topic * @param partition * @return */ public static long getLogSi...

(还有多少消息数未读取(Lag=logSize-Offset))为负数;其中此种情况的删除操作...运行./kafka-topics.sh -delete -zookeeper [zookeeper server] -topic [topic...

2015年12月10日 - logSize Lag Owner console-consumer-11758 my-replicated-topic 0 3715607 ...kafka 的 api 提供了 getoffsetbefore 这个接口, 可以获取到最新的offs...

kafka 的 api 提供了 getoffsetbefore 这个接口, 可以获取到最新的offset。把所有的lag加起来就是总的lag更多关于如何获取kafka某topic的Logsize?的问题>>

2015年1月21日 - Kafka中的Message是以topic为基本单位组织的,不同的...读取12个字节,分别是当前MessageSet的offset和size。...• kafka的log存储是怎么设计的? • kafka log...

2015年10月20日 - 指定自己的分组 自己消费的topic会显示kafka总共有多少数据,以及已经被消费了多少条 结果: GROUP TOPIC PID OFFSET LOGSIZE LAG 消费者组 话题id 分区...