安装Kafka-manager

逃离我推掉我的手 2022-11-21 04:16 46阅读 0赞

前言

> 最近平台部署了Kafka集群，为了方便管理于是安装了yahoo开源的一款基于web的管理工具。

# 安装kafka-manager #

前提要求

*  JDK1.8+
 *  编译的主机要能够连接外网

## 1. 下载编译kafka-manager源码包 ##

$ git clone git@github.com:yahoo/kafka-manager.git  
$ cd kafka-manager  
$ sbt clean dist

编译完成：  
![技术分享图片][b785b83639c80f594fb5add968ef445b.png]

## 2. 修改配置文件 ##

配置文件路径：kafka-manager/conf/application.conf  
配置文件内容：

# Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0
    # See accompanying LICENSE file.
    
    # This is the main configuration file for the application.
    # ~~~~~
    
    # Secret key
    # ~~~~~
    # The secret key is used to secure cryptographics functions.
    # If you deploy your application to several instances be sure to use the same key!
    play.crypto.secret="^<csmm5Fx4d=r2HEX8pelM3iBkFVv?k[mc;IZE<_Qoq8EkX_/7@Zt6dP05Pzea3U"
    play.crypto.secret=${?APPLICATION_SECRET}
    
    # The application languages
    # ~~~~~
    play.i18n.langs=["en"]
    
    play.http.requestHandler = "play.http.DefaultHttpRequestHandler"
    play.http.context = "/"
    play.application.loader=loader.KafkaManagerLoader
    
    kafka-manager.zkhosts="10.60.196.222:2181,10.60.196.223:2181,10.60.196.224:2181"
    kafka-manager.zkhosts=${?ZK_HOSTS}
    pinned-dispatcher.type="PinnedDispatcher"
    pinned-dispatcher.executor="thread-pool-executor"
    application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]
    
    akka {
      loggers = ["akka.event.slf4j.Slf4jLogger"]
      loglevel = "INFO"
    }
    
    basicAuthentication.enabled=true
    basicAuthentication.enabled=${?KAFKA_MANAGER_AUTH_ENABLED}
    basicAuthentication.username="admin"
    basicAuthentication.username=${?KAFKA_MANAGER_USERNAME}
    basicAuthentication.password="password"
    basicAuthentication.password=${?KAFKA_MANAGER_PASSWORD}
    basicAuthentication.realm="Kafka-Manager"
    basicAuthentication.excluded=["/api/health"] # ping the health of your instance without authentification
    
    kafka-manager.consumer.properties.file=${?CONSUMER_PROPERTIES_FILE}

**配置部分指令介绍**：

*  kafka-manager.zkhosts="zkhost\_ip:zkhost\_port,..."  
    用于指明kafka连接的zookeeper。如果zookeeper有多个用逗号分隔。如果你不想直接写入配置文件，你可以设置环境变量ZK\_HOSTS，在配置文件中是用\{?ZK\_HOSTS\}引用即可。  
    要想kafka-manager可以运行起来修改此配置即可。
 *  application.features=\["features1","features2",...\]  
    设置kafka-manager对kafka集群具有的功能。有下面这四个功能  
    KMClusterManagerFeature：容许kafka manager添加，更新，删除kafka集群  
    KMTopicManagerFeature：容许kafka manager在kafka集群中添加，更新，删除topic  
    KMPreferredReplicaElectionFeature：容许kafka manager在kafka集群中执行优先复制选举  
    KMReassignPartitionsFeature：容许kafka manager 生成分区设置，或重置分区设置。
 *  basicAuthentication.enabled  
    是否启动basic认证，启用使用true，不启用使用false。当启用是此选项是，用户请求访问资源时，服务器将会返回401，浏览器就会弹出一个认证框让用户认证，这一过程被称为质询。
 *  basicAuthentication.username  
    启用basic认证时，认证的用户名
 *  basicAuthentication.password  
    启用basic认证时，认证的密码
 *  basicAuthentication.realm  
    可以看成是一个解释，认证用于什么。此字符串在弹出认证框上显示出来
 *  basicAuthentication.excluded=\["/api/health"\]  
    对kafka manager进行健康状态检测，不需要认证

## 3. 运行kafka manager ##

~\]\# cp /root/kafka-manager/kafka-manager-1.3.3.16/target/universal/kafka-manager-1.3.3.16.zip /opt  
~\]\# unzip kafka-manager-1.3.3.16.zip  
~\]\# ln -sv kafka-manager-1.3.3.16/ kafka-manager  
~\]\# cd kafka-manager  
~\]\# bin/kafka-manager -Dconfig.file=/conf/application.conf -Dhttp.port=888  
\-Dconfig.file：指明kafaka manager的配置文件  
\-Dhttp.port： 配置kafka manager监听的端口  
\-java-home： 指明jdk的路径，例如-java-home /usr/local/oracle-java-8

直接bin/kafka-manager此程序，会运行在前台。可以使用nohup bin/kafka-manager -Dconfig.file=/conf/application.conf -Dhttp.port=888 &运行在后台

## 4. 访问kafak manager ##

在浏览器中访问此URL: [http://196.168.196.235:888][http_196.168.196.235_888] 即可。  
**测试basic认证**  
![技术分享图片][07ec0d4ceab6daf2bf4f5306b73e4428.png]

**健康状态检测**  
![技术分享图片][0d4d5fbce718c6d1d346c0b35c3f0443.png]

## 5. 管理集群 ##

**添加集群**  
![技术分享图片][012ff379e40673ee44f13d9557289eb6.png]

kafka的版本号要选安装时的版本，填好后点击添加即可。

![技术分享图片][e0445be98c1f5f64a9457ec0f5e6e140.png]

**查看集群**

![技术分享图片][1a65e21e7d975efd226610c3b928a766.png]

在此页面你可以，操作在配置文件中开放的所有功能。

原文地址：http://blog.51cto.com/13589448/2068095

[b785b83639c80f594fb5add968ef445b.png]: /images/20221120/b0f20daa1930403c8f74c71d1f70bbc6.png
[http_196.168.196.235_888]: http://196.168.196.235:888/
[07ec0d4ceab6daf2bf4f5306b73e4428.png]: /images/20221120/0d78b54ddb2f4be3b70b49986d1bf35b.png
[0d4d5fbce718c6d1d346c0b35c3f0443.png]: /images/20221120/10d540527200441fa8f652be8c7f14e7.png
[012ff379e40673ee44f13d9557289eb6.png]: /images/20221120/db2ce078bd6e447785a3d8d2dd8432fa.png
[e0445be98c1f5f64a9457ec0f5e6e140.png]: /images/20221120/f78d6525dccd4aa5b043440cc348eebb.png
[1a65e21e7d975efd226610c3b928a766.png]: /images/20221120/6793d6272e7b4edab872fce1a05722b0.png