zoukankan      html  css  js  c++  java
  • KafkaOffsetMonitor使用方法

    (1)下载jar包

    去网上搜索KafkaOffsetMonitor即可。

    我这里共享了我的百度云连接:http://yun.baidu.com/s/1nvGjbDn

    如果某一天我这个取消共享了,大家去网上随便查找一个就可以。也可以在博客上给我留言,我来继续分享。

    (2)将jar包上传到Linux上

    我这里在kafka的bin目录下面,建立了一个kafka-monitor的目录,然后将jar包上传上去。

    (3)编写脚本文件

    脚本文件内容如下:

    #!/bin/sh

    java -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.93.128:2181 --port 8089 --refresh 10.seconds --retain 1.days

    (4)运行脚本文件

    设置脚本权限:chmod 777 kafka-monitor.sh

    运行脚本文件:./kafka-monitor.sh &   (后面加上&可以后台运行脚本

    运行成功之后的效果如下图:

    (5)打开浏览器窗口:

    浏览器地址:192.168.93.128:8090

    正常打开之后的效果如下图:

    topic:创建时topic名称

    partition:分区编号

    offset:表示该parition已经消费了多少条message

    logSize:表示该partition已经写了多少条message

    Lag:表示有多少条message没有被消费。

    Owner:表示消费者

    Created:该partition创建时间

    Last Seen:消费状态刷新最新时间。

    --END--

  • 相关阅读:
    前后端分离项目本地测试跨域问题配置
    STS没有找到Dynamic Web Project
    java常见面试题
    log4jdbc 使用
    Thymeleaf 入门
    集成maven和Spring boot的profile 专题
    ftp命令大全
    windows下安装redis
    linux安装环境
    atmega328 熔丝
  • 原文地址:https://www.cnblogs.com/quchunhui/p/5378336.html
Copyright © 2011-2022 走看看