zoukankan      html  css  js  c++  java
  • kafka-manager:kafak的管理界面的安装和使用

    下载打包

    release下载:https://github.com/yahoo/kafka-manager/releases

    源码位置:https://github.com/yahoo/kafka-manager

    从上面两处获取的都是源码,需要自己打包,才可以使用

    1、进入解压后的 Kafka-manager 目录,执行下面的命令:./sbt clean dist。如果之前从来没有用过Play框架,这个步骤会需要一定时间,主要是下载依赖的jar包,使用aliyun的私服可以让这个过程缩短很多。

    2、命令执行完成后,在 target/universal 目录中会生产一个zip压缩包kafka-manager-x.x.x.zip。将压缩包拷贝到要部署的目录下解压。

    3、在解压后的conf目录中打开 application.conf文件,修改其中的配置信息,最主要的内容为:

    kafka-manager.zkhosts="192.168.1.221:2181,192.168.1.222:2181,192.168.1.223:2181"

    配置为Kafka的 zookeeper 服务器。你还可以通过环境变量ZK_HOSTS配置这个参数值。

    4、可以设置为登录验证,增强访问的安全性:

    修改kafka-manager-1.3.3.21/conf/application.conf文件,使Kafka-Manager使用账号登录

    basicAuthentication.username="admin"
    basicAuthentication.password="admin"

    启动,默认端口9000:

    • bin/kafka-manager
    • nohup bin/kafka-manager -Dhttp.port=8090 > nohup.out 2>&1 & 

    配置集群

    点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面:

    输入集群的名字(如Kafka-Cluster-1)和 Zookeeper 服务器地址(如localhost:2181)。

    选择最接近的Kafka版本,直接保存即可

    注意:如果没有在 Kafka 中配置过 JMX_PORT,千万不要选择第一个复选框。
    Enable JMX Polling
    如果选择了该复选框,Kafka-manager 可能会无法启动。

    参考:

    1、https://blog.csdn.net/yuan_xw/article/details/79188565

    2、https://cloud.tencent.com/developer/article/1349478

    3、https://github.com/yahoo/kafka-manager

  • 相关阅读:
    AndroidStudio项目CMakeLists解析
    Xposed那些事儿 — xposed框架的检测和反制
    从谷歌官网下载android 6.0源码、编译并刷入nexus 6p手机
    编译Xposed
    常用的delphi 第三方控件
    delphi安装控件
    delphi控件安装与删除
    从今天开始,每天都要写博客,加油
    关于ArrayAdapter的getCount()的方法会造成空指针异常的分析
    实现ListView的加载更多的效果,如何将按钮布局到始终在ListView的最后一行
  • 原文地址:https://www.cnblogs.com/shengulong/p/10222952.html
Copyright © 2011-2022 走看看