kafka window環境下使用（內置zookeeper）

下載

1. kafka 官網下載最新版本（已集成 zookeeper）
2. 解壓到 D 盤的 kafka_2.12-2.3.0

運行 zookeeper

3. 執行 zookeeper 運行命令

   D:\kafka_2.12-2.3.0\bin\windows\zookeeper-server-start.bat D:\kafka_2.12-2.3.0\config\zookeeper.properties
   

4. 執行結果
   

5. 默認端口號是 2181

運行 kafka

1. 打開新的命令行，執行：

   D:\kafka_2.12-2.3.0\bin\windows\kafka-server-start.bat D:\kafka_2.12-2.3.0\config\server.properties
   

2. 執行結果：

創建主題

1. 創建一個名為 topic_test 的主題，包含一個分區，只有一個副本

   D:\kafka_2.12-2.3.0\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test
   

生產消息

D:\kafka_2.12-2.3.0\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topic_test

消費消息

D:\kafka_2.12-2.3.0\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test --from-beginning