kafka集群搭建(图文并用)

2022-01-12 21:51:56

将安装包上传服务器并解压

scp kafka_2.11-1.0.0.tgz username@{ip}:~/.

mkdir /usr/local/kafka

mv kafka_2.11-1.0.0.tgz /usr/local/kafka/.

cd /usr/local/kafka

tar zxvf kafka_2.11-1.0.0.tgz
```

# 创建软连接
```
cd /usr/local/kafka

ln -s kafka_2.11-1.0.0 inuse
```

# 配置kafka的环境变量
A：
```
vi /etc/profile
```
B：添加内容：
```
export KAFKA_HOME=/usr/local/kafka/inuse
export PATH=$PATH:$KAFKA_HOME/bin
```
C：重新编译文件：
```
source /etc/profile
```
# 修改三台节点的配置文件

进入kafka的config目录
```
cd /usr/local/kafka/inuse/config
```
修改配置文件server.properties
```
vim server.properties

修改以下配置（如果没有该配置项则手动添加）

broker.id=25 (kafka节点的标识，多节点的id不允许相同，建议同ip的最末位序号保持一致)
port=9092
num.partitions=2 原先的配置为1
zookeeper.connect={ip1}:{port1},{ip2}:{port2},{ip3}:{port3}（如172.16.204.23:2181,172.16.204.24:2181,172.16.204.25:2181）
message.max.byte=5048576
default.replication.factor=1
replica.fetch.max.bytes=5048576
host.name={本机ip}
log.dirs=/usr/local/kafka/log
kafka3节点的ip，分别填入host.name