安装 kafka集群(端口:9092)
安装 zookeeper集群:
参见:源码安装 zookeeper集群3.4.11下载压缩包:
wget https://archive.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz
解压:
tar -xzf kafka_2.12-2.2.0.tgz mv kafka_2.12-2.2.0 /usr/local/kafka
创建日志目录:
mkdir /usr/local/kafka/logs
修改配置文件,分别给每台机器分配 broker.id(1、2、3):
vim /usr/local/kafka/config/server.properties
broker.id=1 log.dirs=/usr/local/kafka/logs zookeeper.connect=10.0.0.11:2181,10.0.0.12:2181,10.0.0.13:2181 delete.topic.enable=true
分别启动服务:
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
添加命令到环境变量:
vim /etc/profile
export KAFKA_HOME=/usr/local/kafka export PATH=$PATH:$KAFKA_HOME/bin
. /etc/profile
安装 kafka-manager
下载压缩包:
wget http://file.job520.net/linux/other/kafka-manager-2.0.0.2.zip
解压:
unzip kafka-manager-2.0.0.2.zip mv kafka-manager-2.0.0.2 /usr/local/kafka-manager
修改配置文件:
vim /usr/local/kafka-manager/conf/application.conf
# 修改为 zookeeper集群地址 kafka-manager.zkhosts="10.0.0.11:2181,10.0.0.12:2181,10.0.0.13:2181"
启动:
/usr/local/kafka-manager/bin/kafka-manager -Dconfig.file=/usr/local/kafka-manager/conf/application.conf -Dhttp.port=8080
访问地址:
10.0.0.11:8080
文档更新时间: 2024-04-20 10:57 作者:lee