文档章节

kafka监控之kafka-run-class.sh

 张欢19933
发布于 2017/03/17 19:22
字数 290
阅读 409
收藏 1

kafka自带了很多工具类,在源码kafka.tools里可以看到:

这些类该如何使用呢,kafka的设计者早就为我们考虑到了,在${KAFKA_HOME}/bin下,有很多的脚本,其中有一个kafka-run-class.sh,通过这个脚本,可以调用其中的tools的部分功能,如调用kafka.tools里的ConsumerOffsetChecker.scala,

./kfka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect=192.168.199.129:2181,192.168.199.130:2181,192.168.199.131:2181 --group=group-1

执行结果如下:列出了所有消费者组的所有信息,包括Group(消费者组)、Topic、Pid(分区id)、Offset(当前已消费的条数)、LogSize(总条数)、Lag(未消费的条数)、Owner

细看kafka-run-class.sh脚本,它是调用 了ConsumerOffsetChecker的main方法,所以,我们也可以通过java代码来访问scala的ConsumerOffsetChecker类,代码如下:

package com.wxj.kafka.monitor.jmx;

import kafka.tools.ConsumerOffsetChecker;

/**
 * kafka自带很多工具类,其中ConsumerOffsetChecker能查看到消费者消费的情况,
 * 只可惜,ConsumerOffsetChecker只是将信息打印到标准的输出流中
 * @author root
 *
 */
public class RunClass
{

	public static void main(String[] args)
	{
		//group-1是消费者的group名称,可以在zk中
		String[] arr = new String[]{"--zkconnect=192.168.199.129:2181,192.168.199.130:2181,192.168.199.131:2181","--group=group-1"};
		ConsumerOffsetChecker.main(arr);
		
	}
	
}

 跟通过kafa-run-class.sh执行的结果是一样一样的

本文转载自:http://jxauwxj.iteye.com/blog/2233925

粉丝 47
博文 533
码字总数 244932
作品 0
海淀
私信 提问
Kafka学习之四 Kafka常用命令

Kafka学习之四 Kafka常用命令 Kafka常用命令 以下是kafka常用命令行总结: 1.查看topic的详细信息 ./kafka-topics.sh -zookeeper 127.0.0.1:2181 -describe -topic testKJ1 2、为topic增加副...

舒文joven
2018/07/19
78
0
kafka常用命令

以下是kafka常用命令行总结: 1.查看topic的详细信息 ./kafka-topics.sh -zookeeper 127.0.0.1:2181 -describe -topic testKJ1 2、为topic增加副本 ./kafka-reassign-partitions.sh -zookee......

51zhangyanfeng
2017/07/04
0
0
kafka的简单shell命令管理

启动kafka步骤 1、先启动zookeeper(kafka自带zookeeper的,可以启动自身的)当前目录为bin目录上一级 ./bin/zookeeper-server-start.sh config/zookeeper.properties & (启动后,基本上当前...

qq_38872310
2018/04/16
0
0
kafka 的offset的重置

转载自:https://www.cnblogs.com/hd-zg/p/5831219.html 最近在spark读取kafka消息时,每次读取都会从kafka最新的offset读取。但是如果数据丢失,如果在使用Kafka来分发消息,在数据处理的过...

weixin_37589896
2017/11/29
0
0
Apache Kafka学习(三)之Kafka常用命令

1、开启zookeeper(在安装目录下使用命令) Linux:bin/zkServer.sh start windows:binzkServer.cmd 2、启动kafka(安装目录下使用命令) Linux:bin/kafka-server-start.sh start config/se...

zqcju
07/05
59
0

没有更多内容

加载失败,请刷新页面

加载更多

如何编写高质量的 JS 函数(1) -- 敲山震虎篇

本文首发于 vivo互联网技术 微信公众号 链接:https://mp.weixin.qq.com/s/7lCK9cHmunvYlbm7Xi7JxQ 作者:杨昆 一千个读者,有一千个哈姆雷特。 此系列文章将会从函数的执行机制、鲁棒性、函...

vivo互联网技术
34分钟前
4
0
学会这5个Excel技巧,让你拒绝加班

在网上,随处都可以看到Excel技巧,估计已看腻了吧?但下面5个Excel技巧会让你相见恨晚。关键的是它们个个还很实用 图一 技巧1:快速删除边框 有时当我们处理数据需要去掉边框,按Ctrl+Shif...

干货趣分享
今天
11
0
JS基础-该如何理解原型、原型链?

JS的原型、原型链一直是比较难理解的内容,不少初学者甚至有一定经验的老鸟都不一定能完全说清楚,更多的"很可能"是一知半解,而这部分内容又是JS的核心内容,想要技术进阶的话肯定不能对这个...

OBKoro1
今天
9
0
高防CDN的出现是为了解决网站的哪些问题?

高防CDN是为了更好的服务网络而出现的,是通过高防DNS来实现的。高防CDN是通过智能化的系统判断来路,再反馈给用户,可以减轻用户使用过程的复杂程度。通过智能DNS解析,能让网站访问者连接到...

云漫网络Ruan
今天
15
0
OSChina 周一乱弹 —— 熟悉的味道,难道这就是恋爱的感觉

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @xiaoshiyue :好久没分享歌了分享张碧晨的单曲《今后我与自己流浪》 《今后我与自己流浪》- 张碧晨 手机党少年们想听歌,请使劲儿戳(这里)...

小小编辑
今天
3.3K
25

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部