如何通过安装PHP扩展来接入和使用Kafka？

本文共计569个文字，预计阅读时间需要3分钟。

本章节为大家介绍如何在PHP 7环境下安装Kafka扩展。以下是一种扩展安装方法，并附有参考价值，供朋友们参考。

一、安装librdkafka

1. 下载librdkafka源码包：[librdkafka](https://github.com/edenhill/librdkafka)

2.解压源码包：`tar -zxvf librdkafka-.tar.gz`

3.编译安装：`./configure --prefix=/usr/local/librdkafka && make && make install`

二、安装PHP Kafka扩展

1. 下载PHP Kafka扩展源码包：[php-kafka](https://github.com/edenhill/php-kafka)

2.解压源码包：`tar -zxvf php-kafka-.tar.gz`

3.将源码包中的`ext/kafka`目录下的`kafka.c`和`kafka.h`文件复制到PHP源码目录下的`ext`目录中。

4.修改PHP配置文件（如`php.ini`）：

- 添加扩展目录：`extension_dir=/usr/local/php/lib/php/extensions/no-debug-non-zts-20190902/` - 添加扩展：`extension=kafka`

5. 重启PHP服务。

三、测试安装

1. 创建一个PHP文件，例如`test.php`，内容如下：phpset('bootstrap.servers', 'localhost:9092');$conf->set('group.id', 'test-group');$conf->set('auto.offset.reset', 'earliest');

$producer=new \Kafka\Producer($conf);$producer->produce('test-topic', 0, 'Hello, Kafka!');

$consumer=new \Kafka\Consumer($conf);$consumer->subscribe(['test-topic']);

while ($message=$consumer->consume(1000)) { switch ($message->err) { case \Kafka\Errno::NO_ERROR: echo Received message: . $message->payload . \n; break; case \Kafka\Errno::TIMED_OUT: echo Timed out.\n; break; default: echo Error: . $message->errstr . \n; }}?>

2.运行PHP文件：`php test.php`

如果一切顺利，你应该会看到以下输出：

Received message: Hello, Kafka!

这样，你就成功地在PHP 7环境下安装了Kafka扩展。希望对大家有所帮助！

本篇文章给大家介绍一下php7安装kafka扩展的方法。有一定的参考价值，有需要的朋友可以参考一下，希望对大家有所帮助。

一、安装librdkafka

# cd /usr/local/src/ # git clone github.com/edenhill/librdkafka.git # cd librdkafka # ./configure # make # make install # ln -s /usr/local/lib/librdkafka.so.1 /usr/lib/

二、安装php-rdkafka

# cd /usr/local/src/ # git clone github.com/arnaud-lb/php-rdkafka.git # cd php-rdkafka # /usr/local/php/bin/phpize # ./configure --with-php-config=/usr/local/php/bin/php-config # make all -j 5 # make install

三、修改php.ini # vi /etc/php.ini ##增加如下代码：## extension=rdkafka.so ##查看是否安装成功：## # /usr/local/php/bin/php -m

四、重启php-fpm

# service php-fpm restart

推荐学习：php视频教程