mac kafka 環境搭建 以及PHP的kafka擴展

1.kafka安裝

brew install kafkaphp

安裝會依賴zookeeper。git

注意:安裝目錄:/usr/local/Cellar/kafka/0.10.2.0github

2.安裝的配置文件位置

/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.propertiesbootstrap

3. 啓動zookeeper

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

4.啓動 kafka 服務

cd /usr/local/Cellar/kafka/0.10.2.0
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &服務器

5.建立topic

讓咱們使用單個分區和只有一個副本建立一個名爲「test」的主題ide

./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test工具

Created topic 「test」.命令行

6.查看建立的topic

咱們如今能夠看到該主題,若是咱們運行list topic命令:server

./bin/kafka-topics --list --zookeeper localhost:2181

test

7.發送一些消息

Kafka提供了一個命令行客戶端,它將從文件或標準輸入接收輸入,並將其做爲消息發送到Kafka集羣。默認狀況下,每行都將做爲單獨的消息發送。

運行生產者,而後在控制檯中鍵入一些消息發送到服務器。

bin / kafka-console-producer.sh --broker-list localhost:9092 --topic test
第一條消息
第二條消息

8.消費消息

Kafka還有一個命令行消費者,將消息轉儲到標準輸出。

./bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

第一條消息
第二條消息

若是你有上面的每一個命令運行在不一樣的終端,那麼你如今應該可以輸入消息到生產者終端,看到他們出如今消費者終端。

全部命令行工具都有其餘選項; 運行沒有參數的命令將顯示詳細記錄它們的使用信息。

#安裝librdkafka
git clone https://github.com/edenhill/librdkafka.git
cd librdkafka
./configure
make
make install

#安裝php-rdkafka
git clone https://github.com/arnaud-lb/php-rdkafka.git
cd php-rdkafka
phpize
./configure
make all -j 5
make install
#在php.ini加入以下信息
vim /usr/local/php/etc/php.ini
extension=rdkafka.so

這個時候使用php -m 能夠看到拓展列表內存在 rdkafka這項證實拓展已經安裝成功

相關文章
相關標籤/搜索