云主机测评网云主机测评网云主机测评网

云主机测评网
www.yunzhuji.net

Linux下PHP安装kafka扩展模块

在Linux下安装PHP的Kafka扩展模块,可以按照以下步骤进行:

(图片来源网络,侵删)

1、安装Kafka

首先需要安装Kafka,可以使用官方提供的二进制包进行安装,以Ubuntu为例,执行以下命令:

sudo aptget update
sudo aptget install librdkafkadev

2、下载PHP Kafka扩展模块

从GitHub上下载PHP Kafka扩展模块的源代码:

git clone https://github.com/phprdk/phprdkafka.git

3、编译安装PHP Kafka扩展模块

进入phprdkafka目录,执行以下命令进行编译安装:

cd phprdkafka
phpize
./configure withlibrdkafka=/usr/local/lib
make && make install

4、配置PHP环境

编辑php.ini文件,添加以下内容:

extension=rdkafka.so

重启PHP服务:

sudo service php7.4fpm restart

5、验证安装是否成功

创建一个名为test.php的文件,内容如下:

<?php
$conf = new RdKafkaConf();
$conf>set('bootstrap.servers', 'localhost:9092');
$consumer = new RdKafkaKafkaConsumer($conf);
$consumer>subscribe(['test']);
while (true) {
    $message = $consumer>consume(120*1000); // 120 seconds to consume messages with a maximum delay of 100ms.
    if ($message>err()) { continue; } // Error occurred while consuming message, skip it and continue.
    var_dump($message); // Dump the received message to the screen.
}
?>

运行以下命令启动一个简单的Kafka服务器:

docker run d rm name kafka p 9092:9092 spotify/kafka:lateststrimzi kafkaserverstart.sh config/server.properties override listeners=PLAINTEXT://:9092 override advertised.listeners=PLAINTEXT://:9092 interactive

然后运行以下命令测试PHP Kafka扩展模块是否安装成功:

php test.php

如果看到类似以下的输出,说明PHP Kafka扩展模块已经成功安装并可以正常工作:

object(RdKafkaMessage)#1 (8) { ["payload":"RdKafkaMessagePayload":private]=> object(RdKafkaMessagePayload)#2 (6) { ["message":"string"]=> string(13) "Hello, World!" ["key":"array"]=> array(0) { } ["partition":"int"]=> int(0) ["offset":"int"]=> int(0) ["timestamp":"int"]=> int(1628753676) ["err":"NULL"]=> NULL } ["err":"NULL"]=> NULL ["topic":"string"]=> string(4) "test" ["partition":"int"]=> int(0) ["offset":"int"]=> int(0) ["timestamp":"int"]=> int(1628753676) ["err":"NULL"]=> NULL } [...其他属性] }
打赏
版权声明:主机测评不销售、不代购、不提供任何支持,仅分享信息/测评(有时效性),自行辨别,请遵纪守法文明上网。
文章名称:《Linux下PHP安装kafka扩展模块》
文章链接:https://www.yunzhuji.net/internet/188515.html

评论

  • 验证码