kafka的安裝,在安裝kafka會將其依賴的zookeeper下載

brew install kafka

進入到/usr/local/Cellar 路徑之下會看見軟體位置

/usr/local/Cellar/zookeeper

/usr/local/Cellar/kafka

其中的配置檔案都在kafka路徑之下的config 目錄裡面

/usr/local/Cellar/kafka/config

啟動zookeeper

zookeeper-server-start /usr/local/Cellar/kafka/config/zookeeper.properties &

 

啟動kafka服務

kafka-server-start /usr/local/Cellar/kafka/config/server.properties &

建立topic  zhang

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic zhang

檢視建立的topic

kafka-topics --list --zookeeper localhost:2181

生產者生產資料

kafka-console-producer --broker-list localhost:9092 --topic zhang
 

消費者消費資料

kafka-console-consumer --bootstrap-server localhost:9092 --topic zhang --from-beginning