環(huán)境安裝
安裝kafka
brew install kafka
- kafka使用zookeeper管理，安裝過程會自動安裝zookeeper
- 安裝目錄：/usr/local/Cellar/kafka/* (*為具體安裝的版本)
- 配置文件目錄：/usr/local/etc/kafka
注意：
Homebrew 源沒有修改的可以先跳過
control + c
更多技術(shù)分享-公眾號：碼農(nóng)架構(gòu)
修改kafka啟動配置文件
vi /usr/local/etc/kafka/server.properties
? 該配置為單機版，集群配置請查看博客后續(xù)文章
? 修改kafka的監(jiān)聽地址和端口為localhost:9092
listeners=PLAINTEXT://localhost:9092
依次啟動服務(wù)
brew services start zookeeper
brew services start kafka
? 由于kafka依賴zookeeper管理，所以zookeeper需要先啟動
創(chuàng)建topic
使用單個分區(qū)和只有一個副本的方式來創(chuàng)建一個名為“test”的topic
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看創(chuàng)建的topic
kafka-topics --list --zookeeper localhost:2181
生產(chǎn)消息
通過控制臺向“test”topic添加消息
kafka-console-producer --broker-list localhost:9092 --topic test
消費消息
通過控制臺消費“test”topic中的消息
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
