brew install kafkaphp
安裝會依賴zookeeper。git
注意:安裝目錄:/usr/local/Cellar/kafka/0.10.2.0github
/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.propertiesbootstrap
./bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &vim
cd /usr/local/Cellar/kafka/0.10.2.0
./bin/kafka-server-start /usr/local/etc/kafka/server.properties &服務器
讓咱們使用單個分區和只有一個副本建立一個名爲「test」的主題ide
./bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test工具
Created topic 「test」.命令行
咱們如今能夠看到該主題,若是咱們運行list topic命令:server
./bin/kafka-topics --list --zookeeper localhost:2181
test
Kafka提供了一個命令行客戶端,它將從文件或標準輸入接收輸入,並將其做爲消息發送到Kafka集羣。默認狀況下,每行都將做爲單獨的消息發送。
運行生產者,而後在控制檯中鍵入一些消息發送到服務器。
bin / kafka-console-producer.sh --broker-list localhost:9092 --topic test
第一條消息
第二條消息
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這項證實拓展已經安裝成功