第一步 安裝

brew install kafka

默認(rèn)會把zookeeper一起裝好
安裝路徑

/usr/local/Cellar/zookeeper/3.4.14
/usr/local/Cellar/kafka/2.3.0

配置文件路徑

/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties

第二步 啟動

kafka是基于zookeeper的，啟動kafka之前，需要先啟動zookeeper

啟動zookeeper

進(jìn)入到安裝路徑 cd /usr/local/etc/kafka

zookeeper-server-start zookeeper.properties &  啟動

ps aux | grep zookeeper 查看是否啟動成功

啟動kafka

kafka-server-start server.properties & 啟動

ps aux | grep kafka 查看是否啟動成功

第三步 測試

進(jìn)入kafka安裝目錄

cd /usr/local/Cellar/kafka/2.3.0

創(chuàng)建一個topic

bin/kafka-topics --create --zookeeper localhost:9092--replication-factor 1 --partitions 1 --topic my_first_topic

create 創(chuàng)建主題命令
zookeeper localhost:9092 指定zookeeper
replication-factor 1 指定副本個數(shù)
partitions 1 指定分區(qū)個數(shù)
topic my_first_topic 主題名稱為my_first_topic

查看topic列表

kafka-topics --list --zookeeper localhost:9092
# 輸出：
__consumer_offsets
my_first_topic

創(chuàng)建一個生產(chǎn)者

# 新啟動一個窗口輸入命令創(chuàng)建一個生產(chǎn)者
kafka-console-producer --broker-list localhost:9092 --topic my_first_topic

創(chuàng)建一個消費(fèi)者

# 打開啟動一個（多個）窗口輸入命令創(chuàng)建一個（多個）消費(fèi)者
kafka-console-consumer --bootstrap-server localhost:9092 --topic sunday --from-beginning

效果

生產(chǎn)者

image.png

消費(fèi)者

image.png

最后 關(guān)閉

# 停止kafka
/usr/local/Cellar/kafka/2.3.0/bin/kafka-server-stop
# 停止zookeeper
/usr/local/Cellar/kafka/2.3.0/bin/zookeeper-server-stop