DiDi Kafka-Manager 安装和简单使用

之前本来想装 kafka-manager，现在叫做 CMAK，后来发现滴滴开源的 kafka-manager，功能更丰富。看了下它的架构图和源码，还是很值得参考和借鉴的。

让我们来看看 didi kafka-manager 官网介绍的功能：

一站式 ApacheKafka集群指标监控与运维管控平台

主要功能特性

集群监控维度

• 多版本集群管控，支持从 0.10.2到 2.4版本；

• 集群 Topic、Broker 等多维度历史与实时关键指标查看；

集群管控维度

• 集群运维，包括逻辑 Region 方式管理集群；

• Broker 运维，包括优先副本选举；

• Topic 运维，包括创建、查询、扩容、修改属性、数据采样及迁移等；

• 消费组运维，包括指定时间或指定偏移两种方式进行重置消费偏移；

用户使用维度

• 管理员用户与普通用户视角区分；

• 管理员用户与普通用户权限区分；

kafka-manager 架构图

安装手册

环境依赖

• Maven3.5.0+(后端打包依赖)

• node v8.12.0+(前端打包依赖)

• Java8+(运行环境需要)

• MySQL 或 PostgreSQL(数据存储)

环境初始化

mysql 建库 kafka-manager，执行初始化脚本 createmysqltable.sql，从而创建所需的 MySQL 库及表，默认创建的库名是 kafka_manager。

打包

执行 mvn install命令即可。

备注：每一次执行 mvn install命令，都将在 web/src/main/resources/templates下面生成最新的前端资源文件，如果 console模块下的代码没有变更，可以修改 ./pom.xml文件，忽略对 console模块的打包。

在对 console 执行 npm 的过程中遇到下面的错误：

“Unexpected end of JSON input while parsing near···”

解决方法：先清除缓存，再重新安装

清除缓存命令

npm cache clean --force

在重新执行命令

启动

############# application.yml 是配置文件cp web/src/main/resources/application.yml web/target/cd web/target/nohup java -jar kafka-manager-web-1.0.0-SNAPSHOT.jar --spring.config.location=./application.yml > /dev/null 2>&

由于集群 8080 端口被占用，我们改成了 9005

Web 界面

用管理员帐号 admin/admin 登录

我们需要添加 kafka 集群

这里注意，我们 CDH 中 zookeeper 的连接地址为 cdh1.macro.com:2181,cdh2.macro.com:2181,cdh3.macro.com:2181/kafka