學(xué)習(xí)任何技術(shù),就跟學(xué)自行車一樣, 不要一開始只關(guān)注它的具體細(xì)節(jié)是什么.先學(xué)著怎么騎, 騎著騎著就了解大致的原理, 這個時候再去看他的原理,會很輕松.
入門篇(一)
一义起、安裝
1. mac下安裝kafka
- 1 . 注：沒有HomeBrew的先去官網(wǎng)看文檔安裝, 很簡單的一句話燃辖。
- 2 . 安裝kafka
brew install kafak
-
注意：安裝目錄：/usr/local/Cellar/kafka/0.10.2.0
2. 安裝的配置文件位置
/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties
二接奈、快速啟動
3. 啟動zookeeper
cd /usr/local/Cellar/kafka/0.10.2.0
./bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &
4.啟動 kafka 服務(wù)
cd /usr/local/Cellar/kafka/0.10.2.0
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &
5.創(chuàng)建topic/集群/分區(qū)
./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
6.查看創(chuàng)建的topic/分區(qū)
./bin/kafka-topics --list --zookeeper localhost:2181 test
7.發(fā)送一些消息
- 運(yùn)行生產(chǎn)者，然后在控制臺中鍵入一些消息發(fā)送到服務(wù)器兼蜈。
cd /usr/local/Cellar/kafka/0.10.2.0
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &
./bin/kafka-console-producer --broker-list localhost:9092 --topic test
8.消費(fèi)消息
- Kafka-消費(fèi)者攘残，將消息轉(zhuǎn)儲到標(biāo)準(zhǔn)輸出。(注:另開一個終端來啟動消費(fèi)者)
cd /usr/local/Cellar/kafka/0.10.2.0
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &
./bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
如果分終端運(yùn)行的話,可以同步看到消息 :
生產(chǎn)者終端生產(chǎn)消息
消費(fèi)者終端消費(fèi)消息
到這里就會簡單的 kafka使用了.
