windows搭建kafka入門

2021-10-14 08:02:38 字數 1316 閱讀 2907

解壓出來。我的版本是2.6

要啟動kafka，要先啟動zookeeper，這裡使用kafka自帶的zookeeper。

修改config目錄下的server.properties檔案，修改

log.dirs=f:\kafka_2.13-2.6.0\kafkalogs

可以新建乙個資料夾用來存放kafka的資料資訊存放位址。

修改config目錄下的zookeeper.properties檔案，加入或者修改

datadir=f:\kafka_2.13-2.6.0\data\zookeeper

配置檔案到這裡就可以了。

先開始啟動zookeeper，在bin/windows目錄下開啟命令列，輸入

zookeeper-server-start.bat ../../config/zookeeper.properties
zookeeper啟動成功後，啟動kafka：

kafka-server-start.bat ../../config/server.properties
kafka啟動成功後，建立乙個topic：

kafka-run-class.bat kafka.admin.topiccommand --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hellotest
topic的名字是hellotest。

建立生產者：

kafka-console-producer.bat --broker-list localhost:9092 --topic hellotest
然後在生產者視窗中就可以發訊息了。

然後建立消費者：

kafka-console-consumer.bat --zookeeper localhost:2181 --topic hellotest --from-beginning
報錯了，說是zookeeper is not a recognized option。

查了下因為版本，zookeeper命令已經不再使用了

修改命令為：

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic hellotest --from-beginning
啟動成功，接收到了剛才發的訊息了然後在生產者中再次輸入訊息，消費者視窗中就可以立刻接受到了。

完成

windows環境kafka服務搭建

kafka配置 kafka簡單演示 參考 kafka是用於構建實時資料管道和流應用程式。具有橫向擴充套件，容錯，wicked fast 快 等優點，並已在成千上萬家公司執行。詳細可檢視官網 以下進入主題，環境搭建 本示例使用版本是zookeeper 3.4.13 配置環境變數 在系統環境變數中新增 ...

Kafka單機Windows環境搭建

kafka單機windows環境搭建 1，安裝jdk1.8 安裝目錄不能有中文空格 解壓到d zookeeper 3.4.11之後，在conf目錄下面重新命名zoo sample.cfg為zoo.cfg，在zoo.cfg修改如下內容 datadir d zookeeper 3.4.11 data d...

kafka集群搭建（windows環境

準備三份 每個zk都建立這兩個資料夾 在每個zkdata都建立myid檔案，沒有字尾名 內容分別寫著 1 2 3 zk3.8 1 寫的1，3.8 2寫的2 類推 myid的數字和server.x對應 除了clientport修改為2081,2082,2083之外別的照抄，由於是乙個電腦操作，只能改埠...