真的是難為我了 有坑!
一定要注意命令有些地方的空格該不該有!
一、准備工作
下載kafka,去阿帕奇官網直接下載就好了
然后jdk也要部署在環境里
zookeeper不知道需不需要部署,反正我是部署上去了,跟部署環境變量一樣的操作
二、運行和測試
注意:在啟動Kafka前,先運行Zookeeper實例。 (前面的cmd命令:zkserver)
在windows下運行 zookeeper-server-start.bat ../../config/zookeeper.properties
成功了就是這樣子
①啟動Kafka服務器
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1 (此處自己所在文件夾下)
.\bin\windows\kafka-server-start.bat .\config\server.properties
②創建主題
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kk
這樣就創建好主題了。
③創建生產者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-producer.bat --broker-list localhost:9092 --topic kk
④創建消費者
新建cmd窗口:
cd D:\Tool\kafka_2.11-2.1.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kk --from-beginning
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
⑤生產消息並消費
以下就完成了
一切截圖本人親測!完工!
給自己加個雞腿!