本文以搭建三个kafka为例：

目录

本文以搭建三个kafka为例：

第一步在kafka的config的文件下，找到server.properties

​

第二步：以server.properties为模板修改server1.properties中的几个属性。

修改broker.id和listeners的端口号

修改log.dirs

第三步：使用命令启动三台服务器：

验证kafka集群是否搭建成功：

---

第一步在kafka的config的文件下，找到server.properties

复制server.properties,创建server1.properties，server2.properties

第二步：以server.properties为模板修改server1.properties中的几个属性。

 注：可以用notepad++来打开server1.properties

修改broker.id和listeners的端口号

修改log.dirs

 再用相同的方法来修改server2.properties

broker.id=2

listeners=PLAINTEXT://10.12.37.140:9094

log.dir=./logs-2

第三步：使用命令启动三台服务器：

在D:\kafka\kafka_2.12-2.7.0\bin\windows路径中启动cmd命令行

在命令行中输入

kafka-server-start.bat ..\..\config\server.properties

运行之后，如法炮制再在D:\kafka\kafka_2.12-2.7.0\bin\windows路径下再打开一个cmd窗口输入

kafka-server-start.bat ..\..\config\server1.properties

server2.properties也是如此。

启动server1.properties和server2.properties相关命令之后的页面

验证kafka集群是否搭建成功：

 在启动zookeeper之后，打开zookeeper客户端，双击zkCli.cmd,在命令行中输入

ls /brokers/ids

 显示红框则表示集群搭建成功。

第四步：发送消息

创建主题：

相关命令

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic test7

 再创建生产者：（连接broker）后面，这个生产者发布消息，三个消费者都能收到。

kafka-console-producer.bat --broker-list 10.12.37.140:9092,10.12.37.140:9093,10.12.37.140:9094 --topic test7

 创建消费者：

kafka-console-consumer.bat --bootstrap-server 10.12.37.140:9092 --topic test7 --from-beginning

 此时还可以更改9092为9093和9094来创建多个消费者

kafka-console-consumer.bat --bootstrap-server 10.12.37.140:9093 --topic test7 --from-beginning

 这样就创建好了kafka集群和对集群进行消费的发送啦。