文档章节

Kafka监控:Kafka-Manager

夜雨寄北09
 夜雨寄北09
发布于 2018/05/03 18:32
字数 419
阅读 737
收藏 0

Kafka Manager是雅虎开发的kafka监控及管理工具,项目地址:https://github.com/yahoo/kafka-manager

安装

下载源码:

git clone https://github.com/yahoo/kafka-manager.git

Kafka Manager是用Scala开发的,通过sbt(Simple Build Tool)构建(类似于Maven和Gradle)。

编译

cd kafka-manager
./sbt clean dist

如果提示“Download failed. Obtain the jar manually and place it at /Users/tongyufu/.sbt/launchers/0.13.9/sbt-launch.jar”,下载sbt-launch.jar失败,可以去网上搜索0.13.9版本的sbt-launch.jar单独下载,并放到~/.sbt/launchers/0.13.9中,或者修改 ./kafka-manager/project/build.properties文件,将sbt.version=0.13.9修改成sbt.version=0.13.17,然后重新执行编译命令。

看到以下信息时,表示编译成功。

[info] Your package is ready in /Users/tongyufu/develop/source/kafka/kafka-manager/target/universal/kafka-manager-1.3.3.17.zip
[info]
[success] Total time: 565 s, completed 2018-5-3 17:54:42

编译成功的文件在kafka-manager/target/universal/kafka-manager-1.3.3.17.zip中,解压该文件。

配置

编辑kafka-manager-1.3.3.17/conf/application.conf,

#修改前
kafka-manager.zkhosts="kafka-manager-zookeeper:2181"
#修改成zookeeper的实际地址,多个地址使用逗号分隔
kafka-manager.zkhosts="127.0.0.1:2181"

启动

bin/kafka-manager

默认访问端口是9000,可以指定端口和配置文件

bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080

关闭

kafka manager没有提供关闭操作的执行脚本和命令,可以通过kill命令强制杀掉kafka manager进程。ProdServerStart就是Kafka Manager的进程,杀掉进程,并删除根目录下的RUNNING_PID文件(有时候启动失败会有此文件,导致再次启动报错:This application is already running (Or delete /Users/tongyufu/develop/source/kafka/kafka-manager-1.3.3.17/RUNNING_PID file).)。

kill 31543
rm -f RUNNING_PID

使用监控功能

访问locaohost:9000,默认页面没有显示任何kafka集群信息,点击顶部的“Cluster”->“Add Cluster”添加集群配置。集群名称随便定义。

 

© 著作权归作者所有

共有 人打赏支持
夜雨寄北09
粉丝 14
博文 17
码字总数 16980
作品 0
浦东
程序员
私信 提问
【Kafka】- 监控工具kafka-manager

Kafkawebconsole: 项目已不支持,推荐kafka-manager(yahoo开源) Kafka-manager配置步骤: 1. 下载sbt: https://www.scala-sbt.org/download.html 2. 配置sbt:配置国内镜像源(类似maven仓库...

ZeroneLove
02/24
0
0
Kafka集群及监控安装指南

kafka官网:http://kafka.apache.org/ 官方文档:http://kafka.apache.org/documentation.html#quickstart kafka集群安装 下载: kafka2.10-0.8.2.0.tar.gz 解压: tar -zxvf kafka2.10-0.8.......

zyqJustin
2016/04/16
409
0
使用Kafka Manager管理Kafka集群

公司使用到了Kafka,想借助一套可视化的工具更好地管理Kafka。笔者将目光瞄准了Kafka Manager。 安装Kafka 一、下载Kafka 前往http://kafka.apache.org/downloads ,根据自己的需要,下载合适...

周立_itmuch
2017/10/20
0
0
kafka管理监控插件

kafka 监控插件 1.KafkaOffsetMonitor 项目地址:https://github.com/quantifind/KafkaOffsetMonitor KafkaOffsetMonitor是用来实时监控Kafka集群的consumers以及它们在partition中的offset(......

Ryan-瑞恩
2015/09/23
514
0
基于Docker搭建分布式消息队列Kafka

本文基于Docker搭建一套单节点的Kafka消息队列,Kafka依赖Zookeeper为其管理集群信息,虽然本例不涉及集群,但是该有的组件都还是会有,典型的kafka分布式架构如下图所示。本例搭建的示例包含...

半夜菊花茶
2017/11/23
0
0

没有更多内容

加载失败,请刷新页面

加载更多

java数组的复制

java数组的复制,因为之前代码写着写着有点懵,所以总结一下记录一下。 主要有以下几种方式: clone System.arraycopy 和 Arrays.copyOfRange Arrays.copyOf for循环 最后需要注意的是基本类...

woshixin
14分钟前
0
0
面试题剖析,如何保证消息队列的高可用?

面试题 如何保证消息队列的高可用? 面试官心理分析 如果有人问到你 MQ 的知识,高可用是必问的。上一讲提到,MQ 会导致系统可用性降低。所以只要你用了 MQ,接下来问的一些要点肯定就是围绕...

李红欧巴
25分钟前
0
0
Java 启动线程并保持

1.等待输入 new BufferedReader(new InputStreamReader(System.in)).readLine();  2.同步锁 synchronized (TopologyServiceServer.class) { while (true) { ......

MrPei
34分钟前
0
0
关于C++ 容器的swap操作

一、swap操作交换两个相同类型的容器的内容,一般的容器(除array外),交换两个容器内容的操作会保证非常快,因为并没有交换元素本身,而只是交换了两个容器的内部数据结构。 拿vector做个例...

shzwork
38分钟前
1
0
程序员从宏观、微观角度浅析JVM虚拟机!

1.问题 1、JAVA文本文件如何被翻译成CLASS二进制文件? 2、如何理解CLASS文件的组成结构? 3、虚拟机如何加载使用类文件的生命周期? 4、虚拟机系列诊断工具如何使用? 5、虚拟机内存淘汰机制?...

我最喜欢三大框架
38分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部