下载地址

kafka:

https://repo.huaweicloud.com/apache/kafka/3.2.1/kafka_2.12-3.2.1.tgz

jdk版本:支持8版本,但是推荐11版本以上。

部署

解压kafka_2.12-3.2.1.tgz 到 /opt/kafka_2.12-3.2.1并做各软连接,方便脚本写路径

tar zxvf kafka_2.12-3.2.1.tgz -C /opt/
cd /opt//
ln -s kafka_2.12-3.2.1 kafka

配置

默认的zookeeper配置文件:/opt/kafka/config/zookeeper.properties,数据目录是放到/tmp/zookeeper,修改一下放到持久化的目录。

kafka配置文件:/opt/kafka/config/server.properties,默认数据目录也是配置到/tmp/kafka-logs,修改到对应的大磁盘目录。

启动脚本:

#!/bin/bash
export JAVA_HOME=/opt/jdk18
export PATH=${JAVA_HOME}/bin:$PATH
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/opt/kafka/bin/kafka-server-start.sh  -daemon /opt/kafka/config/server.properties 

可视化工具

kafka-console-ui

https://github.com/xxd763795151/kafka-console-ui

总结

单节点可以用于测试,生产要搞上集群。