集群搭建

在 Windows 下搭建集群

选择需要下载的版本:Index

这里下载的是 2.8.1,下载地址

zookeeper

首先需要启动 zookeeper

  • 首先,修改 zookeeper 快照的储存目录
    • 在解压出来的的 KAFKA根目录(以下用%KAFKA_HOME%代替) 下找到 conf\zookeeper.properties,修改 dataDir=/tmp/zookeeper,改为dataDir=D:\\tmp\\zookeeper
  • %KAFKA_HOME% 下执行 cmd:
1
start bin\windows\zookeeper-server-start.bat config\zookeeper.properties
  • 关闭 zookeeper
1
bin\windows\zookeeper-server-stop.bat

KAFKA

启动 KAFKA 前,先修改 kafka 数据的存放地址

  • 找到%KAFKA_HOME%\conf\server.properties,将log.dirs=/tmp/kafka-logs,改为log.dirs=D:\\tmp\\kafka
  • %KAFKA_HOME%下执行 cmd:
1
start bin\windows\kafka-server-start.bat config\server.properties
  • 关闭 KAFKA
1
bin\windows\kafka-server-stop.bat

搭建集群

修改 %KAFKA%\config\server.properties,并重新保存为server-1.propertiesserver-2.properties

需要修改的内容

1
2
3
4
5
6
7
8
9
# server-1.properties
broker.id=1
listeners=PLAINTEXT://127.0.0.1:9093
log.dirs=D:\\tmp\\kafka1

# server-1.properties
broker.id=2
listeners=PLAINTEXT://127.0.0.1:9094
log.dirs=D:\\tmp\\kafka2

修改完毕后启动

1
2
start bin\windows\kafka-server-start.bat config\server1.properties
start bin\windows\kafka-server-start.bat config\server2.properties

现在 Kafka 的集群已经搭建完毕了,目前开启了四个 cmd 的窗口(3 台 Kafka 的 broker 和一台 zookeeper),接下篇 Kafka 命令行操作