已安裝Zookeeper 并啟動

1、下載安裝包?

https://link.zhihu.com/?target=https%3A//archive.apache.org/dist/kafka/2.4.1/kafka_2.12-2.4.1.tgz

2.解壓后將config目錄下server.properties文件的log.dirs值修改為如：自己解壓的地址的data目錄下，如圖所示：

啟動監(jiān)聽如圖

3.打開cmd窗口，進入解壓的bin目錄里的windos的bat腳本所在的目錄并執(zhí)行如下命令

kafka-server-start.bat ..\..\config\server.properties

如果沒看到報錯，基本就算啟動成功了

4、創(chuàng)建一個topic為test? ?打開一個新的cmd窗口

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

———————————————————————————————————————————

查看 test主題的詳情 kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test

Topic:test：主體的名稱是test。

Partition：分區(qū)編號是0，代表只有一個分區(qū)，編號從0開始

Leader：每個分區(qū)多個副本的主節(jié)點編號，這個在集群中才會是其它值，這里是單機模式，值等于唯一副本編號

Replicas：副本編號，也是從0開始。

修改分區(qū)數?注意：分區(qū)數只能增加，不能減少

kafka-topics.bat --bootstrap-server localhost:9092 --alter --topic test --partitions 2

刪除 topic

kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic test?

———————————————————————————————————————————

5、在剛才創(chuàng)建topic的窗口里創(chuàng)建一個消息的生產者

kafka-console-producer.bat --broker-list localhost:9092 --topic test

———————————————————————————————————————————
新打開一個cmd窗口，來創(chuàng)建一個消費者來接收生產者生產的消息?

1）消費 test主題中的數據。?只能消費消費者出現之后的數據

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

2）把主題中所有的數據都讀取出來（包括歷史數據）

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

———————————————————————————————————————————
6、然后我們用剛才的生產者來發(fā)送消息，看看消費者能不能收到：

————————————————