zookeeper接入kafka，安装部署CMAK监控kafka，Windows环境

Posted 2022-09-29 zhangphil

zookeeper接入kafka，安装部署CMAK监控kafka，Windows环境

（1）先在Windows下安装部署kafka。

kafka连接zookeeper配置搭建环境、安装和启动，Windows环境下_zhangphil的博客-CSDN博客_kafka zookeeper配置kafka，分布式集群架构下，高性能的流式事件数据（主要是消息）集成、发布（生产）和订阅（分发、消费）组件（中间件）。kafka依赖zooeeper（数据后端），这里有Windows下安装配置启动zookeeper的 文章（1）：Windows 10环境zookeeper单机伪集群部署和配置_Zhang Phil-CSDN博客Windows 10环境zookeeper单机伪集群部署和配置1，首先到zookeeper项目主页地址下载项目包，https://archive.apache.org/disthttps://blog.csdn.net/zhangphil/article/details/123086790

关于zookeeper的配置，几个关键的配置文件内容D:\\program\\zookeeper\\zk1\\program\\conf\\zoo.cfg：

tickTime=2000
initLimit=10
syncLimit=5

dataDir=D:/program/zookeeper/zk1/data
dataLogDir=D:/program/zookeeper/zk1/log

clientPort=2181

server.1=127.0.0.1:2889:3889

server.1对应的myid里面只需写一个数字1即可，D:\\program\\zookeeper\\zk1\\data\\myid:

1

如果是分布式集群，因为zoo.cfg里面有server.1,server.2,server.3...，每个节点的myid文件写上对应的数字编号1，2，3。

Windows环境下，如果是自己编写.bat命令控制台，则可以根据自己的Java环境自定义配置JAVA_HOME：

set JAVA_HOME=C:\\program\\java\\jdk
set path=C:\\Windows\\System32;%JAVA_HOME%\\bin;C:\\Windows\\System32\\wbem;
start cls

kafka中，把config/server.properties里面的listener打开和定义：

 把以上代码保存为.bat文件，打开寻址到bin/windows/下，找到kafka-server-start.bat,启动kafka的命令：

kafka-server-start.bat D:/program/kafka/kafka/config/server.properties

(2)部署安装kafka的监控系统CMAK

在这个地址页面

Releases · yahoo/CMAK · GitHubCMAK is a tool for managing Apache Kafka clusters. Contribute to yahoo/CMAK development by creating an account on GitHub.https://github.com/yahoo/CMAK/releases下载CMAK。解压，最好放到Windows根目录下。

进入/conf目录下，修改配置文件application.conf，里面比较重要的配置项

 这四行，可以把kafka-manager开头的两行注释掉，只保留cmak的配置项目，在本例中，这四行最终只保留一行：

cmak.zkhosts="localhost:2181"

另外，默认的CMAK启动的端口是9000,如果该端口被其他程序占用，可以在application.conf新增加一行写入：

http.port=9001

指定启动端口，上述配置指定cmak在端口9001服务。

（3）启动CMAK。

以上配置完成后，先启动zookeeper，再启动kafka，然后启动cmak，启动cmak，只需要到bin目录下，找到cmak.bat，直接运行即可。

在浏览器访问 localhost:9000 ，进入后是这样一个web管理界面：

需要添加集群。

勾选以上选择项目。

然后再次打开 http://localhost:9000/

就可以看到集群的节点了。

（4）监控kafka性能

需要打开kafka的JMX，找到kafka-server-start.bat文件，在这个位置

增加一行： 

set JMX_PORT="9999"

变为

然后重启Kafka，jmx就有数据展示了：