实战：部署三台kafka服务集群

欢迎围观+留言评论

部署三台kafka服务集群

安装Java环境

sudo yum update
sudo yum install java-1.8.0-openjdk-devel
java -version
1
2
3

准备kafka安装包

kafka_2.13-2.8.2.tgz
1

上传到服务器

解压缩

tar -xzf kafka_2.13-2.8.2.tgz
1

建立软链接

ln -s /opt/kafka_2.13-2.8.2 /opt/kafka
1

编辑配置文件

 vim /opt/kafka/config/server.properties
# Broker ID，确保每个broker的ID不同
broker.id=1  # 对于第一个节点，设置为1；其他节点设置为2, 3
# 对应自己的kafka的ip
listeners=PLAINTEXT://ip1:9092
# 对应自己的kafka的ip
advertised.listeners=PLAINTEXT://ip1:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/opt/data/kafka
num.partitions=16
default.replication.factor=2
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=3
transaction.state.log.replication.factor=3
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18