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

一.准备工具

• 已编译好的Kafka-manager安装压缩包(下载)

二.操作步骤

    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.运行成功,出现以下页面

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

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

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

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