搜索
您的当前位置:首页正文

【Kafka零基础学习】用源代码在本地搭建集群环境

来源:哗拓教育

一、搭建第一个broker

二、搭建第二个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
Top