Kafka伪集群部署
1.安装Kafka
[root@localhost ~]# tar -xvf kafka_2.12-2.5.0.tgz -C /usr/local/
[root@localhost ~]# cd /usr/local/
[root@localhost local]# mv kafka_2.12-2.5.0/ kafka
2.在config里面有一个server.properties文件，你需要几个伪节点就复制几份，建议是单数
[root@localhost local]# cd kafka/config/
[root@localhost config]# mv server.properties server1.properties
[root@localhost config]# cp server1.properties server2.properties
[root@localhost config]# cp server1.properties server3.properties
3.修改server.properties文件(三份文件都需要修改)
[root@localhost ~]# vim /usr/local/kafka/config/server1.properties
修改参数
broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/usr/local/kafka/logs/log1
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
[root@localhost ~]# vim /usr/local/kafka/config/server2.properties
broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=/usr/local/kafka/logs/log2
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
[root@localhost ~]# vim /usr/local/kafka/config/server3.properties
broker.id=2
listeners=PLAINTEXT://:9094
log.dirs=/usr/local/kafka/logs/log3
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
4.启动Kafka
先启动zookeeper再启动Kafka
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka1/config/server1.properties
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka2/config/server2.properties
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka3/config/server3.properties
5.检查，使用jps命令如果能看到Kafka的数量和你启动的数量一致，则是启动成功了
[root@localhost ~]# jps
1316 QuorumPeerMain
2485 Kafka
1194 QuorumPeerMain
2090 Kafka
3948 Jps
1246 QuorumPeerMain
1694 Kafka