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