環境安裝
安裝kafka
brew install kafka
- kafka使用zookeeper管理,安裝程序會自動安裝zookeeper
- 安裝目錄:/usr/local/Cellar/kafka/* (*為具體安裝的版本)
- 組態檔目錄:/usr/local/etc/kafka
注意:
Homebrew 源沒有修改的可以先跳過
control + c

修改kafka啟動組態檔
vi /usr/local/etc/kafka/server.properties
? 該配置為單機版,集群配置請查看博客后續文章
? 修改kafka的監聽地址和埠為localhost:9092
listeners=PLAINTEXT://localhost:9092
依次啟動服務
brew services start zookeeper
brew services start kafka
? 由于kafka依賴zookeeper管理,所以zookeeper需要先啟動
創建topic
使用單個磁區和只有一個副本的方式來創建一個名為“test”的topic
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看創建的topic
kafka-topics --list --zookeeper localhost:2181
生產訊息
通過控制臺向“test”topic添加訊息
kafka-console-producer --broker-list localhost:9092 --topic test
消費訊息
通過控制臺消費“test”topic中的訊息
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
Kafka 開發應用實戰
Kafka 實戰案例
Kafka 核心原理解讀

CSDN認證博客專家
軟體架構師
B站網紅UP
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/254045.html
標籤:其他
