zoukankan      html  css  js  c++  java
  • kafka tools的使用

    项目中会使用kafka tools,主要看变更消息有没有被监听到

    目录

    1、下载与配置

    2、排查问题

    1、下载与配置

    完成下载安装http://www.kafkatool.com/download.html

    配置连接:

     配置字符类型:在Tools -->Settings --> Topics,将 Key 和 Message 均设置为String 保存。这样是全局设置,对所有 Topic 均生效

    选中topics下的一个partition,然后点击data中的执行,查看message即可

     

    2、排查问题

    问题一:查看生产者是否发了消息

    执行完动作后,然后点击工具中的运行,然后根据日期倒叙显示,就可以看到最新的消息里面是否有自己执行动作产生的消息,如果数据库有变更,kafka中没有生产者的消息,那就是监听机制有问题,如果数据库没变更就是数据库有问题

     问题二:消息是否有堆积(生产者消息没问题,最终结果没有变化,那就是消费者出现问题,有可能是消息堆积)

    根据问题一中的方法,可以拿到最新消息的offset,然后去服务器上查看最近一条消费的消息的offset,观察2者之前偏移量的差距就可以看到有没有堆积

    此外,像mq是有后台登录的,是可以直接看到消息是否有堆积,kafka应该也有后台,具体可以自己研究

    本文中图片使用https://blog.csdn.net/Dongguabai/article/details/86526299完成,如有侵权,请联系删除

  • 相关阅读:
    转载:Cgroups 与 Systemd
    转载:linux cgroups 简介
    深入剖析Linux IO原理
    Tomcat zabbix监控、jmx监控、zabbix_java_gateway
    Tomcat 打开jmx
    vsftp、ftps 搭建
    Tomcat 调优
    Tomcat 部署及配置
    SVN 搭建
    Nginx 编译安装
  • 原文地址:https://www.cnblogs.com/weizhideweilai/p/13538063.html
Copyright © 2011-2022 走看看