kafka安裝與啟動

一、安裝

brew install kafka

image.png

• 默認(rèn)安裝上zookeeper

• 安裝好kafka

• 根據(jù)安裝提示找到安裝位置和配置文件路徑，以及啟動方式

• 安裝路徑

/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

二、 啟動

啟動zookeeper

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

/usr/local/Cellar/kafka/2.3.0/bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

啟動后，查看啟動是否成功

ps aux | grep zookeeper

啟動kafka

/usr/local/Cellar/kafka/2.3.0/bin/kafka-server-start /usr/local/etc/kafka/server.properties &

驗(yàn)證是否啟動成功

ps aux | grep kafka

三、測試

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

cd /usr/local/Cellar/kafka/2.3.0

創(chuàng)建一個(gè)topic

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

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

查看topic列表

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

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

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

• 生產(chǎn)者發(fā)送消息

  
  
  image.png

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

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

• 消費(fèi)者接收消息

  
  
  image.png

四、關(guān)閉kafka服務(wù)

服務(wù)關(guān)閉的順序是先kafka，然后zookeeper

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