# 首先在保證php已經正確安裝的情況下：

# 安裝jdk(本人安裝jdk7) 和 scala ?因為kafka基于scala開發

# 之后解壓安裝包 進入 運行命令 ./gradlew jar # 會下載一些包 # 首先運行 zookeeper ./bin/zookeeper-server-start.sh ./config/zookeeper.properties

# 之后運行kafka ./bin/kafka-server-start.sh ./config/server.properties

# 接下來安裝PHP的kafka擴展

# 下載 wget https://github.com/EVODelavega/phpkafka/archive/master.zip

# 之后進入文件夾 phpize ./configure ?--enable-kafka --with-php-config=/usr/local/php/bin/php-config make

# 出現問題

# 解決

# 下載 wget https://github.com/edenhill/librdkafka/archive/master.zip

# 之后安裝

# 安裝成功之后在重新安裝kafka擴展

# 如果出現錯誤 沒有config.h.in的提示

# 需要用autoheader創建出來

php -m | grep kafka

# 說明擴展安裝成功 # 之后測試

# 測試代碼在README中

$kafka = new Kafka("localhost:9092");

$kafka->produce("topic_name", "message content");

//get all the available partitions

$partitions = $kafka->getPartitionsForTopic('topic_name');

//use it to OPTIONALLY specify a partition to consume from

//if not, consuming IS slower. To set the partition:

$kafka->setPartition($partitions[0]);//set to first partition

//then consume, for example, starting with the first offset, consume 20 messages

$msg = $kafka->consume("topic_name", Kafka::OFFSET_BEGIN, 20);

var_dump($msg);//dumps array of messages

總結

以上是生活随笔為你收集整理的kafka php 0.8,php5.6 centos7 kafka0.8.1的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。