macOS啟動Kafka

目錄

• kafka目錄結構
• 先啟動zookeeper
• 后啟動kafka
• 創建topic
• 創建一個生產者
• 創建一個消費者

---

kafka目錄結構

# kafka安裝目錄
/usr/local/Cellar/kafka/2.6.0

# 配置文件目錄
/usr/local/etc/kafka/

# 如果超時，在server.properties中增加
zookeeper.connection.timeout.ms=6000000

先啟動zookeeper

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

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

# 不使用配置啟動的方式
zkServer start
zkServer stop

檢測是否啟動成功
ps aux | grep zookeeper

(上圖為啟動成功時截圖)

后啟動kafka

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


# zk如果使用配置啟動，kafka也得使用配置啟動，不然會報錯
cd /usr/local/Cellar/kafka/2.6.0/bin
./kafka-server-start /usr/local/etc/kafka/server.properties &

檢測是否啟動成功
ps aux | grep kakfka

(上圖為啟動成功時截圖)

創建topic

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

查看topic list
kafka-topics --list --zookeeper localhost:2181

要是報：Timed out waiting for connection while in state: CONNECTING ，那就是沒有啟動zk、kafka

創建一個生產者

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

進入指定生產者
kafka-console-producer --broker-list localhost:9092 --topic basket_test

創建一個消費者

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