有 3 台服务器, ip 分别为 192.168.174.10,192.168.174.11,192.168.174.12.
官网下载, 分别在每台机器上解压安装
- # 创建 kafka 的安装目录
- mkdir -p /usr/local/software/kafka
- # 解压
- tar -xvf kafka_2.12-1.1.0.tgz -C /usr/local/software/kafka/
修改每台服务器的 / etc/profile 文件, 设置 kafka 环境变量, 添加如下内容
- export KAFKA_HOME=/usr/local/software/kafka/kafka_2.12-1.1.0
- export PATH=$PATH:$KAFKA_HOME/bin
添加完后重启配置, 命令如下:
source /etc/profile
修改每台服务器的 $KAFKA_HOME/config 下的 server.properties 文件, 修改代理 id 和日志存放目录
- # 指定代理 id,borker.id 可以任意指定, 前提是保证集群内每台机器的 broker.id 唯一, 第二台机器设置为 2... 以此类推
- broker.id=1
- # 设置日志目录
- log.dirs=/opt/data/kafka/kafka-logs
- # 设置 zookeeper 集群地址
- zookeeper.connect=192.168.174.7:2181,192.168.174.8:2181,192.168.174.9:2181
- # 设置本机地址, 设置为本服务器的 ip 地址. 如果不设置会在创建主题和发送消息时, 发生 NOT LEADER FOR PARTITION 异常.
- host.name=192.168.174.10
配置完成后, 分别启动 3 台服务器的 kafka, 启动 kafka 前确保 zookeeper 集群已经成功启动.
kafka-server-start.sh -daemon server.properties
验证是否成功启动 jps
如果看到 kafka 进程, 说明启动成功.
另外也可通过 zookeeper 客户端查看 zookeeper 目录结构, 如下:
- # 登录 zookeeper
- zkCli . sh -server 192.168.174.7:2181
- # 查看目录结构
- ls /
- # 查看已启动的 kafka 代理
- ls /brokers/ids
来源: http://www.bubuko.com/infodetail-2667646.html