參考文章: https://www.jianshu.com/p/2509c32b396d?utm_campaign=maleskine&utm_content=note&utm_medium=seo_notes&utm_source=recommendation
注意:1、本來想安裝kafka_2.12-3.0.0的, 結果發現在win10上有bug。最后只能放棄。 bug參考地址:https://blog.csdn.net/u010843408/article/details/120909099
為了安全,多降幾個版本,最后選擇2.8.1版本
2、提前安裝好zookeeper, 我時在win10默認安裝的zk。在啟動kafka前,需要先啟動zookeeper。
第一步:下載kafka 並解壓,下載地址:https://dlcdn.apache.org/kafka/2.8.1/

第二步: 可省略。 配置kafka的日志: 打開config/server.properties.

修改日志的路徑,即修改log.dirs:
我沒有修改,會默認在E盤創建tmp/kafka-logs目錄。
第三步:啟動kafka(需要先啟動zookeeper)
.\bin\windows\kafka-server-start.bat .\config\server.properties

第四步:創建主題,同一個主題創建一次即可。
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2

第五步:啟動生產者和消費者
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test2
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2 --from-beginning


生產者發送數據,消費者就可以收到數據了。
