一、搭建第一个broker
二、搭建第二个broker
1、在config文件夹中增加server2.properties,内容保持与server.properties相同。如下图所示。
2、修改server2.properties中的部分属性配置。
配置如下:
broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=/tmp/kafka-logs2
3、Run/Debug Configuration
image.png
三、搭建第三个broker
1、在config文件夹中增加server3.properties,内容保持与server.properties相同。如下图所示。
2、修改server3.properties中的部分属性配置。
配置如下:
broker.id=2
listeners=PLAINTEXT://:9094
log.dirs=/tmp/kafka-logs3
3、Run/Debug Configuration
四、启动zookeeper
使用zkServer启动zookeeper。
image.png
五、分别在idea中启动broker1,broker2,broker3。
如下图所示,分别选中kafka,kafka2,kafka3并选择标红按钮运行。
image.png
六、测试集群的正确性
1、在命令行中创建具有三个备份的topic test3
2、可以观察到topic test3的三个备份被分散到了各个broker的日志目录下。这说明集群环境搭建成功。