## 一、安装包准备

测试环境(单机,无安全认证)

操作系统版本
CentOS Linux release x86_647.5.1804 (Core)

测试软件版本

软件版本
zookeeper3.7.0
kafka2.4.0
cmak3.0.0.5
jdk11.0.12

版本要求

  • zookeeper需要在3.5.0以上版本
  • kafka版本Kafka 0.8.. or 0.9.. or 0.10.. or 0.11…
  • cmak版本3.0.0.5
  • jdk版本11以上(oracle官网或openjdk11)

下载链接

https://github.com/yahoo/CMAK/releases/download/3.0.0.5/cmak-3.0.0.5.zip
https://archive.apache.org/dist/kafka/2.4.0/kafka_2.11-2.4.0.tgz
https://archive.apache.org/dist/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz

二、更改配置文件

解压安装包,进行配置

tar -zxf apache-zookeeper-3.7.0-bin.tar.gz && mv apache-zookeeper-3.7.0-bin zookeeper
tar -zxf kafka_2.11-2.4.0.tgz && mv kafka_2.11-2.4.0 kafka
unzip cmak-3.0.0.5.zip &7 mv cmak-3.0.0.5 cmak

zookeeper配置

# 进入zookeeper安装目录,conf目录下
mv zoo_sample.cfg zoo.cfg
# 编辑配置文件(使用默认配置)
dataDir=/tmp/zookeeper # 根据实际情况更改

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-u3UwbL4s-1636970635793)(/Users/xiaohu/Library/Application Support/typora-user-images/image-20211115175011970.png)]

初始化zookeeper

bin/zkServer-initialize.sh
/usr/bin/java
ZooKeeper data directory already exists at /tmp/zookeeper (or use --force to force re-initialization)
# 启动zookeeper
bin/zkServer.sh start 2>&1 > /dev/null &
# 日志目录 zookeeper安装目录logs、

kafka配置

更改以下两项,其他使用默认配置
# kafka安装目录conf文件夹server.properties文件
listeners=PLAINTEXT://localhost:9092 
zookeeper.connect=localhost:2181 # 默认znode为kafka
启动kafka
bin/kafka-server-start.sh ./config/server.properties 2>&1 > /dev/null
# 日志默认存放在kafka_home(安装目录)logs下

cmak配置

# cmak/conf目录下application.conf文件
kafka-manager.zkhosts="localhost:2181"
cmak.zkhosts="localhost:2181"
basicAuthentication.enabled=true
启动cmak
cmak/bin/cmak -Dconfig.file=./cmak/conf/application.conf -Dhttp.port=9000 -java-home ./jdk-11.0.12 2>&1 > /dev/null &
# 日志路径
cmak/logs/application.log

三、查看cmak-webui并添加集群

在这里插入图片描述

添加集群

在这里插入图片描述

更改自定义配置

在这里插入图片描述

添加完成后查看集群信息

在这里插入图片描述
在这里插入图片描述

topics详情页

在这里插入图片描述

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐