由于外界很多安装kafka-manager的教程,这里就不在做过多的详细概述,只是简单的过一下,主要讲安装遇到的问题。
一、安装概述
kafka-manager的代码可以从https://github.com/yahoo/kafka-manager下载.
由于官网并没有编译好的包,只能通过sbt来构建运行版本; 由于构建版本比较慢,如果有需要,可以直接从我的网盘下载构建好的版本。[链接: https://pan.baidu.com/s/1oXC78VLCW3FuhSIv7OsOsg 提取码: 943m ]
- 安装sbt
sbt是scala的打包构建工具
ubuntu下可以通过:
echo "deb https://dl.bintray.com/sbt/debian /" | sudo tee -a /etc/apt/sources.list.d/sbt.list
sudo apt-get update
sudo apt-get install sbt
进行安装。
- 下载kafka-manager,进行编译
git clone https://github.com/yahoo/kafka-manager
cd kafka-manager
sbt clean dist
如果没有设置代理,这个操作会很慢,在我的机器上至少编译了10多分钟(下载scala依赖包,从远程拉取jar包,然后构建发布版本).
然后再kafka-manager/target/universal
目录下会生成一个kafka-manager zip包,将该zip复制到你的安装目录即可。
- 配置
修改kafka-manager/conf/application.conf,配置成如下:
//这里设置成你的zk地址,如果有多个以逗号进行分割
kafka-manager.zkhosts="xxx:2181"
//下面这个同名key不要删除,保持不动
kafka-manager.zkhosts=${?ZK_HOSTS}
- 启动
cd kafka-manager/bin
./kafka-manager -Dconfig.file=../conf/application.conf
如果要指定端口,可以在后面追加参数: -Dhttp.port=端口号
如果通过jps
看到ProdServerStart
进程,说明程序正常启动. 可以通过ip:port访问web了。
- 异常情况
可能第一次配置的application.conf有问题,导致程序启动的时候进程起不来,看日志也只能输出:
This application is already running (Or delete RUNNING_PID file)
尝试将conf下的logger.xml和logback.xml日志级别调到debug,也没有输出其它异常错误日志。
最后,将kafka-manager下的RUNNING_PID文件删除,就可以正常启动成功了(可能是kafka-manager防止重复启动进程做的一个操作)