windows系統下kafka_2.12-2.0.0的安裝配置

Step 1: 準備安裝包並解壓

  1. 下載kafka_2.12-2.0.0,下載地址http://kafka.apache.org/quickstart
  2. 配置zokeeper, 爲何須要配置zokeeper,zokeeper和kafka的關係什麼?如見https://blog.csdn.net/u011311291/article/details/85264046
  3. 解壓kafka_2.12-2.2.0.tgz,下載包裏面包括window和linux兩種啓動文件,見如圖

Step 2: 啓動kafka

  1. 上面講到了Kafka用到了Zookeeper,全部首先啓動Zookper,Zookper支持集羣模式下啓動, 咱們先用單點方式啓動Zookkeeper服務。

進入kafka解壓目錄,執行bin\windows\zookeeper-server-start.bat config/zookeeper.properties命令, , 見到INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)等字樣,表示啓動成功。linux


  1. 啓動kafka 進入kafka解壓目錄,執行bin\windows\kafka-server-start.bat config/server.properties命令, , 見到如圖的字眼表示成功

   

Step 3: 使用kafka

  1. topic操做 建立一個叫作「kafka1」的topic,它只有一個分區,一個副本. bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka1
  2. 查看已建立的topic bin\windows\kafka-topics.bat -list --zookeeper localhost:2181
  3. 消息測試 Kafka 使用一個簡單的命令行producer,從文件中或者從標準輸入中讀取消息併發送到服務端。默認的每條命令將發送一條消息。 運行producer並在控制檯中輸一些消息,這些消息將被髮送到服務端,發送消息時需帶上topic,因接受消息的時也是監聽topic的: bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafka1 啓動consumer接受消息 bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka1 --from-beginning

基礎的安裝已完成了,固然後續還有對broker的集羣操做等,這裏先講到這裏。apache

相關文章
相關標籤/搜索