php rdkafka安装的方法:首先下载安装librdkafka;然后安装php-rdkafka扩展;最后在php.ini中写入“extension=rdkafka.so”即可。
php入门到就业线上直播课:进入学习
Apipost = Postman + Swagger + Mock + Jmeter 超好用的API调试工具:点击使用
本文操作环境: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 如何安装的详细内容,更多请关注php中文网其它相关文章!