20190312 Windows上Kafka集羣

1. 複製config/server.properties爲server1.properties和server2.properties

2. 以server1.properties爲例，修改配置

broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=E:\\Develop\\kafka\\2.11-2.1.1\\kafka_2.11-2.1.1\\kafka-logs1
zookeeper.connect=localhost:12181,localhost:12182,localhost:12183

3. 啓動ZooKeeper集羣

配置ZooKeeper集羣可參考

• 20190311 Windows安裝ZooKeeper
• 20190311 Windows上ZooKeeper僞集羣的實現

4. 啓動Kafka集羣

分別啓動配置的server1和server2

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

5. 驗證集羣成功

在一個Kafka上啓動一個生產者：

PS E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1> .\bin\windows\kafka-console-producer.bat --broker-list localhost:9093 --topic test

在另外一個Kafka上啓動一個消費者：

PS E:\Develop\kafka\2.11-2.1.1\kafka_2.11-2.1.1> .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9094 --topic test

若是，生產者上發送的消息，在消費者上能夠接收到，證實集羣成功。

參考資料

Kafka官網