Window系统下Kafka可视化管理工具Kafka-manager的安装与配置

小咪咪 2022-05-08 11:06 1869阅读 0赞

## 一.准备工具 ##

*  ### 已编译好的Kafka-manager安装压缩包([下载][Link 1]) ###

## 二.操作步骤 ##

### 1.解压缩安装包,最好跟之前的Kafka包,Zookeeper包在同一目录下,这样方便修改管理. ###

### 2.修改D:\\KafkaTool\\kafka-manager-1.3.3.16\\conf目录下的application.conf文件,将kafka-manager.zkhosts修改为本地或需要的远程服务器链接,这里修改为 ###

kafka-manager.zkhosts="localhost:2181"

### 3.为了使Kafka-manager兼容Kafka和Zookeeper,这里需要修改Kafka和Zookeeper的一些配置文件,在D:\\KafkaTool\\zookeeper-3.4.12\\conf目录下修改zoo.cfg,修改的主要内容为: ###

dataDir=D:\\KafkaTool\\zookeeper-3.4.12\\data
    dataLogDir=D:\\KafkaTool\\zookeeper-3.4.12\\log

### 4.在D:\\KafkaTool\\kafka\_2.10-0.10.2.1\\config的操作目录下修改server.properties(之前安装操作做了一些修改,这里补充),主要修改内容为: ###

# The number of messages to accept before forcing a flush of data to disk
    log.flush.interval.messages=10
    
    # The maximum amount of time a message can sit in a log before we force a flush
    log.flush.interval.ms=320000

# root directory for all kafka znodes.
    zookeeper.connect=localhost:2181
    
    # Timeout in ms for connecting to zookeeper
    zookeeper.connection.timeout.ms=18000

### 主要是为了避免日志的短期操作缓存过期.在这期间打开Kafka可能会出现以下类似的错误(只截取核心的错误日志信息) ###

at java.lang.Thread.run(Thread.java:745)
    Caused by: java.nio.file.FileSystemException: D:\KafkaTool\kafka_2.10-0.10.2.1\k
    afka-logs\haige-0\00000000000000000000.log -> D:\KafkaTool\kafka_2.10-0.10.2.1\k
    afka-logs\haige-0\00000000000000000000.log.deleted: 另一个程序正在使用此文件，进
    程无法访问。

### 这是Kafka在Window平台上存在的一个Bug,**只能手动删除\\kafka-logs里的日志文件重启kafka,才能再次正确运行Kafka.至于Kafka-manager,要删除D:\\KafkaTool\\kafka-manager-1.3.3.16\\bin目录下之前运行产生的日志文件夹application.home\_IS\_UNDEFINED和RUNNING\_PID文件.在必要时还要删除D:\\KafkaTool\\zookeeper-3.4.12\\log文件夹下的version-2文件夹和D:\\KafkaTool\\zookeeper-3.4.12\\data文件夹下的version-2.** ###

###  **5.点击D:\\KafkaTool\\kafka-manager-1.3.3.16\\bin文件夹下的kafka-manager.bat,运行kafka-manager.运行成功,出现以下页面** ###

**![70][]**

###  **运行出错,该CMD执行框会闪退,这时可以检查之前的步骤都做了吗?** ###

###  **6.在浏览器输入**[http://localhost:9000/][http_localhost_9000]访问**kafka-manager的主页** ###

**![70 1][]**

### 7.在Cluster下拉框选择Add Cluster添加一个集群节点,这里简单操作,在输入框Cluster Name和Cluster Zookeeper Hosts填入必要值即可,其他选项默认.点击Save保存即可 ###

![70 2][]

### 8.这时就可以在网页上对刚才新建的haige集群节点做消息队列的管理了 ###

![70 3][]

[Link 1]: https://download.csdn.net/download/linhaiyun_ytdx/10713468
[70]: /images/20220508/aed3a26c9ace4ec89cafdff60dcd98a6.png
[http_localhost_9000]: http://localhost:9000/
[70 1]: /images/20220508/ab1b548312e54f8cb686ae7055f5411c.png
[70 2]: /images/20220508/1c44097f4a0646fe933dfc52d2753cd4.png
[70 3]: /images/20220508/dd8bf0dca19442eb9af4935355f487ac.png