本文操作环境：windows7系统、php7.0版，dell g3电脑
php-rdkafka 扩展安装
php有两种方式调用kafka
php-rdkafka文档地址：https://arnaud-lb.github.io/php-rdkafka/phpdoc/book.rdkafka.html
rdkafka安装需要依赖librdkafka所以我们需要先安装librdkafka
下载地址http://pecl.php.net/package/rdkafka
git clone https://github.com/edenhill/librdkafka.gitcd librdkafka./configuremake && make install
安装php-rdkafka扩展
git clone https://github.com/arnaud-lb/php-rdkafka.gitcd php-rdkafkaphpize./configure --with-php-config=/usr/local/php7.0/bin/php-configmake && make install
然后在php.ini写入
extension = rdkafka.so
kafka-php 扩展包文档地址：https://github.com/weiboad/kafka-php
简单示例生成者
<?php$rk = new rdkafka\producer();$rk->setloglevel(log_debug);$rk->addbrokers(192.168.2.152);$topic = $rk->newtopic(shop);for ($i = 0; $i < 10; $i++) { $topic->produce(rd_kafka_partition_ua, 0, 发送信息： $i); $rk->poll(0);}while ($rk->getoutqlen() > 0) { $rk->poll(50);}?>
消费者
<?php$conf = new rdkafka\conf();$conf->set('group.id', 'myconsumergroup');$rk = new rdkafka\consumer($conf);$rk->addbrokers(192.168.2.150:9092);$topicconf = new rdkafka\topicconf();$topicconf->set('auto.commit.interval.ms', 100);$topicconf->set('offset.store.method', 'file');$topicconf->set('offset.store.path', sys_get_temp_dir());$topicconf->set('auto.offset.reset', 'smallest');$topic = $rk->newtopic(shop, $topicconf);// start consuming partition 0$topic->consumestart(0, rd_kafka_offset_stored);while (true) { $message = $topic->consume(0, 120*10000); switch ($message->err) { case rd_kafka_resp_err_no_error: //没有错误打印信息 var_dump($message); break; case rd_kafka_resp_err__partition_eof: echo 等待接收信息\n; break; case rd_kafka_resp_err__timed_out: echo 超时\n; break; default: throw new \exception($message->errstr(), $message->err); break; }}?>
推荐学习：《php视频教程》
以上就是rdkafka php 如何安装的详细内容。