近期在搞kafka，在Windows環(huán)境搭建的過(guò)程中遇到一些問題，把具體的流程幾下來(lái)防止后面忘了。?
準(zhǔn)備工作：?
1.安裝jdk環(huán)境?
http://www.oracle.com/technetwork/java/javase/downloads/index.html?
2.下載kafka的程序安裝包：?
http://kafka.apache.org/downloads?
解壓文件提取出里面的文件?
在cmd命令行打開至根目錄下，內(nèi)容如下：?
?
(1).bin目錄下存放的是程序運(yùn)行時(shí)使用的腳本文件，window平臺(tái)是一個(gè)獨(dú)立的文件夾里面存放著 .bat 文件，bin的目錄下存放的是 Linux 平臺(tái)使用的 .sh 的shell腳本，在window平臺(tái)上用不到，嫌麻煩可以刪了。?
(2).config目錄下存放的是一些程序運(yùn)行的配置文件，在后期自定義使用kafka的時(shí)候需要修改里面的文件內(nèi)容。?
(3).libs目錄是打包好的jar包，這個(gè)版本自帶了zookeeper的jar包，所以在安裝的過(guò)程中不需要再在本地安裝zookeeper了。

? ?啟動(dòng)zookeeper：?
? 在正常啟動(dòng)zoopkeeper之前需要修改zookeeper.properties的文件內(nèi)容，將其data的輸出目錄指定一下，可自行創(chuàng)建一個(gè)文件夾如下：?
?
然后啟動(dòng)：

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

正常啟動(dòng)后他的狀態(tài)是這樣的：?
?
3. 啟動(dòng)kfaka服務(wù)：?
在啟動(dòng)前，任然需要修改server.properties中l(wèi)og.dir的配置目錄，?
?
修改后，啟動(dòng)服務(wù)：?
?
4. 創(chuàng)建一個(gè)主題：

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kjTest

可以使用如下命令查看創(chuàng)建的主題列表：

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

?
5. 啟動(dòng)生產(chǎn)者：

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kjTest

此時(shí)可以從控制臺(tái)輸入信息，待消費(fèi)者啟動(dòng)后可接收到生產(chǎn)者發(fā)布的消息。?
?
6. 啟動(dòng)消費(fèi)者：

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic kjTest --from-beginning

此時(shí)便能看到發(fā)布出去的消息了?
?
7. 在后期還可以啟動(dòng)多個(gè)集群服務(wù)，同時(shí)進(jìn)行操作，修改server.properties中的內(nèi)容：便可啟動(dòng)，與上相似。

config/server-1.properties:broker.id=<new id>listeners=PLAINTEXT://:<new port>log.dir=<you log dir> 操作步驟：

1).分別啟動(dòng)需要的kafka服務(wù)

?

?

2). 創(chuàng)建主題，設(shè)置分區(qū)數(shù)目?
?

可以使用下面的命令查看是否創(chuàng)建成功，和具體的分區(qū)?
?

3). 分別啟動(dòng)生產(chǎn)者消費(fèi)者?

?

?

4). 可以查看下當(dāng)前工作狀態(tài)?
?

查看得當(dāng)前服務(wù)使用的是broker編號(hào)為2的服務(wù)，但我們將其down掉后?
?

再次執(zhí)行消息發(fā)送任務(wù)：?

?

?
消息仍能發(fā)送成功，命令行中會(huì)提示一個(gè)服務(wù)已關(guān)閉。?
就查看當(dāng)前狀態(tài)：?
?

此時(shí)的leader換成了broker 0

?轉(zhuǎn)自：https://blog.csdn.net/qq_32485573/article/details/54562237?locationNum=5&fps=1

?

總結(jié)

以上是生活随笔為你收集整理的Windows平台下kafka环境的搭建的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。