主要对比滴滴的kafka-manager 和雅虎的CMAK(原名kafka manager) https://github.com/didi/kafka-manager https://github.com.../yahoo/CMAK 直接上对比结论 比较项 kafka-manager CMAK 社区活跃度 不太活跃但滴滴同学群里响应比较快 比较活跃 开发环境 java8 java11/scala 编译方式
1.3 kafka-manager为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 Kafka Manager。...以上版本适用） 8.为已存在的topic增加分区 9.为已存在的topic更新配置 10.在多个topic上批量重分区 11.在多个topic上批量重分区(可选partition broker位置) kafka-manager...项目地址：https://github.com/yahoo/kafka-manager 二、部署 2.1 初始化环境 初始化系统，关闭防火墙修改主机名与ip名称 名称 HOSTNAME IP 1 kafka...git clone https://github.com/yahoo/kafka-manager cd kafka-manager sbt clean dist #过程比较长 得到文件... 默认的端口是9000，可通过 -Dhttp.port，指定端口; -Dconfig.file=conf/application.conf指定配置文件: nohup bin/kafka-manager
rpm/rpm > bintray-sbt-rpm.repo mv bintray-sbt-rpm.repo /etc/yum.repos.d/ yum install sbt 将github上/kafka-manager...kafka-manager-2.0.0.2/ vim conf/application.conf 修改下 kafka-manager.zkhosts="192.168.2.4:2181" # 这里改成了我们kafka-manager.../bin/kafka-manager -Dconfig.file=./conf/application.conf -Dhttp.port=8080
之前本来想装kafka-manager，现在叫做CMAK，后来发现滴滴开源的kafka-manager，功能更丰富。看了下它的架构图和源码，还是很值得参考和借鉴的。...让我们来看看didi kafka-manager官网介绍的功能： 一站式 ApacheKafka集群指标监控与运维管控平台 主要功能特性 集群监控维度 多版本集群管控，支持从 0.10.2到 2.4版本...Topic运维，包括创建、查询、扩容、修改属性、数据采样及迁移等； 消费组运维，包括指定时间或指定偏移两种方式进行重置消费偏移； 用户使用维度 管理员用户与普通用户视角区分； 管理员用户与普通用户权限区分； kafka-manager...环境依赖 Maven3.5.0+(后端打包依赖) node v8.12.0+(前端打包依赖) Java8+(运行环境需要) MySQL 或 PostgreSQL(数据存储) 环境初始化 mysql建库kafka-manager
简介 kafka-manager是目前最受欢迎的kafka集群管理工具，最早由雅虎开源，用户可以在Web界面执行一些简单的集群管理操作。...kafka-manager server service After=network.target [Service] WorkingDirectory=/path/to/kafka-manager/...cmak-3.0.0.1 ExecStart=/path/to/kafka-manager/cmak-3.0.0.1/bin/cmak -Dconfig.file=/path/to/kafka-manager...启动、停止、重启 $ systemctl start kafka-manager $ systemctl stop kafka-manager $ systemctl restart kafka-manager...# 加入开机启动 $ systemctl enable kafka-manager 配置日志切割 /path/to/kafka-manager/cmak-3.0.0.1/logs/application.log
1.软件下载 kafka-manager 工具目前改名为cmak,下载地址为：https://github.com/yahoo/CMAK/releases/tag/3.0.0.5 现在下载最新版本的cmak...-04 19:49:15,983 - [INFO] k.m.a.DeleteClusterActor - Started actor akka://kafka-manager-system/user/kafka-manager...19:49:17,711 - [INFO] k.m.a.c.BrokerViewCacheActor - Started actor akka://kafka-manager-system/user/kafka-manager...04 19:49:17,712 - [INFO] k.m.a.c.KafkaCommandActor - Started actor akka://kafka-manager-system/user/kafka-manager...19:49:17,712 - [INFO] k.m.a.c.ClusterManagerActor - Started actor akka://kafka-manager-system/user/kafka-manager
批量生成多个主题的分区分配，并可以选择要使用的代理 批量运行分区的多个主题的重新分配 将分区添加到现有主题 更新现有主题的配置 Kafka Manager下载地址 https://github.com/yahoo/kafka-manager...安装包并修改参数 unzip kafka-manager-1.3.3.23.zip mv kafka-manager-1.3.3.23 kafka-manager cd kafka-manager/conf...zookeeper地址与端口 2)、开启用户名密码验证 basicAuthentication.enabled=false改为 basicAuthentication.enabled=true 4、启动kafka-manager...cd /opt/kafka-manager/bin ..../kafka-manager -Dconfig.file=/opt/kafka-manager/conf/application.conf -Dhttp.port=9000 5、添加集群，并查看集群的相关信息
kafka3/docker.sock:/var/run/docker.sock" - "/home/cdata/data1/docker/kafka/kafka3/data/:/kafka" kafka-manager...: image: sheepkiller/kafka-manager:latest restart: unless-stopped container_name: kafka-manager...hostname: kafka-manager ports: - "9000:9000" links: # 连接本compose文件创建的container
一、Kafka-manager简介 Kafka Manager是用于管理Apache Kafka集群的工具。...项目地址：https://github.com/yahoo/Kafka-manager 二、安装 1....下载安装 kafka-manager 2.1 .下载kafka-manager 想要查看和管理Kafka，完全使用命令并不方便，我们可以使用雅虎开源的Kafka-manager，GitHub地址如下：...https://github.com/yahoo/Kafka-manager 我们可以使用Git或者直接从Releases中下载，此处从下面的地址下载kafka-manager-1.3.3.7.zip...版本： https://github.com/yahoo/Kafka-manager/releases 下载完成后解压。
2.Kafka Manager 2.1 部署 https://github.com/yahoo/kafka-manager/archive/1.3.3.15.zip 上传压缩包kafka-manager...KAFKA_MANAGER_PASSWORD} basicAuthentication.realm="Kafka-Manager" 将登录Kafka-Manager的账号密码设置为admin。...使用如下命令启动Kafka-Manager 修改文件的权限 [root@cm1 bin]$ chmod 777 kafka-manager # 默认为9000，但是我的集群有端口冲突，改为8090 [root...到此为止Kafka-Manager就部署成功了。 登录Kafka-Manager管理界面 ? 点击Cluster菜单，添加一个Kafka集群 ? ?...2.2 总结 Kafka-Manager支持Kafka的0.8.x，0.9.x，0.10.x，0.11.x版本 Kafka需要JDK8的环境运行 Kafka-Manager支持管理多个Kafka集群。
3.将Github上的源码clone下来后进入kafka-manager目录，执行如下命令编译 [root@ip-172-31-11-174 ~]# cd kafka-manager/ [root@ip...-172-31-11-174 kafka-manager]# ....到此为止Kafka-Manager编译完成。...将登录Kafka-Manager的账号密码设置为admin。...到此为止Kafka-Manager就部署成功了。 4.Kafka-Manager使用 ---- 1.登录Kafka-Manager管理界面 ? 2.点击Cluster菜单，添加一个Kafka集群 ?
(可选安装) https://github.com/yahoo/kafka-manager https://github.com/yahoo/kafka-manager/archive/2.0.0.2....tar.gz k8s-dns.boysec.cn上: mkdir /data/dockerfile/kafka-manager cd /data/dockerfile/kafka-manager 方法一...docker pull wangxiansen/kafka-manager:v2.0.0.2 #wangxiansen/kafka-manager:v3.0.0.5 docker tag wangxiansen.../kafka-manager:v2.0.0.2 harbor.od.com/infra/kafka-manager:v2.0.0.2 docker push harbor.od.com/infra/kafka-manager...spec: containers: - name: kafka-manager image: harbor.od.com/infra/kafka-manager
你可以很轻松的安装他： # 从git上下载Kafka manager源码 git clone https://github.com/yahoo/kafka-manager # 使用sbt进行编译，编译过程中需要等待很长时间...kafka-server-start -daemon /usr/local/etc/kafka/server.properties 之后，运行以下命令启动 Kafka Manager： # 进入/kafka-manager.../kafka-manager/bin # 执行kafka-manager命令 sh kafka-manager 然后我们就可以新建Cluster，点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面...一个完整的过程你可以参考： 《Kafka集群管理工具kafka-manager部署安装》https://blog.csdn.net/qq_43631716/article/details/120109732
172.16.218.203 172.16.218.201 kafka1 172.16.218.202 kafka2 172.16.218.203 kafka3 172.16.200.48 kafka-manager...三、安装kafka-manager 功能： 为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 Kafka Manager。...源码，并编译打包 # cd /usr/local # git clone https://github.com/yahoo/kafka-manager # cd kafka-manager # ..../kafka-manager -Dconfig.file=../conf/application.conf 后台运行： # ./kafka-manager -h # nohup ..../kafka-manager -Dconfig.file=..
2.编译会比较慢 cd kafka-manager 编译会很慢 ....cd kafka-manager 4.配置，填写要管理的zk地址 vim conf/application.conf kafka-manager.zkhosts="192.168.1.35:2181，...192.168.1.10:2181" 5.后台启动 nohup bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=7778...& 三.报错处理 timed out on 这是因为kafka-manager链接zookeeper超时导致的。...检查kafka-manager的配置文件application.conf，zookeeper地址是否正确 while starting up loggers kafka-manager日志显示如下 kafka-manager
' -f 1 | xargs docker rm 二、镜像选择 环境为M1版本的mbp: Zookeeper采用zookeeper Kafka采用wurstmeister/kafka Kafka-Manager...采用scjtqs/kafka-manager Mysql采用mysql/mysql-server 三、集群规划 1....4.安装kafka-manager 4.1 新建文件kafka-manager-docker-compose.yml version: '2' services: kafka-manager:...image: scjtqs/kafka-manager:latest restart: always hostname: kafka-manager container_name...: kafka-manager ports: - 9000:9000 external_links: # 连接本compose文件以外的container -
manager 镜像 docker pull dockerkafka/zookeeper docker pull dockerkafka/kafka docker pull dockerkafka/kafka-manager...kafkadocker_zookeeper_1:zookeeper --link kafkadocker_kafka_1:kafka -p 9000:9000 -e ZK_HOSTS=zookeeper:2181 dockerkafka/kafka-manager..." kafka: image: dockerkafka/kafka ports: - "9092:9092" links: - zookeeper:zookeeper kafka-manager...: image: dockerkafka/kafka-manager environment: - ZK_HOSTS=zookeeper:2181 ports: - "9000:
我们可能听到更多的是 kafka-manager。主要是因为误用了 Apache 的商标，所以才从 kafka-manager 改名为 CMAK。...在 3.0.0.2 版本之前，kafka-manager 是不提供现成的编译包的，需要我们自己编译打包，老版本的安装可以参阅博文 Kafka 监控工具之Kafka Manager。...如果你不想升级你的 ZooKeeper 版本，你可以使用 CMAK 的旧版本 Kafka-manager，比如1.3.3.23版本。...KeeperErrorCode = Unimplemented for /kafka-manager/mutex Try again. 那么你需要升级 Zookeeper 到 3.5+ 版本。
总数据量 LAG：未消费的数据量 CONSUMER-ID：代表消费者id，为空代表当前没有消费者 HOST：消费者主机ip，为空代表当前没有消费者 CLIENT-ID：客户端id，为空代表当前没有消费者 kafka-manager...kafka-manager要比kafka-consumer-groups工具强大的多，它不仅可以用于查看消费者消费情况，同时可以管理Topic，包括创建topic，管理partition。...从下面地址下载kafka-manager的安装包 http://github.com/yahoo/kafka-manager/releases 解压并进入kafka安装目录，使用sbt进行编译，sbt需要配置源.../kafka-manager命令，kafka默认端口是9000，进入管理页面之后配置kafka节点相关信息，就能监控kafka运行情况 如下是kafka-manager的管理界面 查看所有的消费组 ?
zookeeper:2181 volumes: - /data/product/king_bigdata/data/kafka/docker.sock:/var/run/docker.sock kafka-manager...: image: sheepkiller/kafka-manager ## 镜像：开源的web管理kafka集群的界面 environment:...dockerkafka_kafka_1:9092 --from-beginning --topic moni图示:image.pngkafka_manager 连接:访问 ip:9000 如图:image.png关于kafka-manager...Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-system/), Path(/user/kafka-manager)]] after...注意:kafka-manager不支持硬盘挂载
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
