软件版本
kafka_2.12-2.1.1
官网下载：
https://kafka.apache.org/downloads
系统环境
192.168.0.1 | 192.168.0.2 | 192.168.0.3
安装目录 /home
Snipaste_2020-07-21_14-34-20.png
1.安装zookeeper
https://www.jianshu.com/p/6cc82a3ba084
2.安装kafka
首先在 192.168.0.1上解压kafka
tar -zxvf kafka_2.12-2.1.1.tar.gz
创建日志文件 kafka-logs
cd kafka_2.12-2.1.1
mkdir kafka-logs
编辑kafka启动配置文件
vim /conf/server.properties
# 配置如下内容
broker.id=1
listeners = PLAINTEXT://192.168.0.1:9092
log.dirs=/home/kafka_2.12-2.1.1/kafka-logs
zookeeper.connect=192.168.0.1:2181,192.168.0.2:2181,192.168.0.3:2181
将kafka_2.12-2.1.1拷贝到其他两台机器
scp -r /home/kafka_2.12-2.1.1 root@192.168.0.2:/home
scp -r /home/kafka_2.12-2.1.1 root@192.168.0.3:/home
修改配置
# 192.168.0.2
broker.id=2
listeners = PLAINTEXT://192.168.0.2:9092
# 192.168.0.3
broker.id=3
listeners = PLAINTEXT://192.168.0.3:9092
在三台服务器上分别启动kafka服务
./kafka-server-start.sh -daemon ../config/server.properties
创建topic，随意指定节点
./kafka-topics.sh --create --zookeeper 192.168.0.2:2181 --replication-factor 1 --partitions 1 --topic test
向topic发送消息，随意指定节点
./kafka-console-producer.sh --borker-list 192.168.0.3:9092 --topic test
在多个节点上分别消费 test
./kafka-console-consumer.sh --bootstrap-server 192.168.0.1:9092 --topic test --from-beginning
./kafka-console-consumer.sh --bootstrap-server 192.168.0.2:9092 --topic test --from-beginning
./kafka-console-consumer.sh --bootstrap-server 192.168.0.3:9092 --topic test --from-beginning
Snipaste_2020-07-21_14-24-12.png
如上图所示，多节点正常消费，kafka集群搭建成功！
如果觉得还不错，点个赞呗 ！O(∩_∩)O
