PHP Kafka 消息队列使用
- 安装 Kafka 服务（需要先安装java环境）
直接到 kafka 官网, 下载最新的
wget https://downloads.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz
解压，进入目录
tar -zxvf kafka_2.13-3.1.0.tgz
cd kafka_2.13-3.1.0
a. 启动 Kafka 服务
使用安装包中的脚本启动单节点 Zookeeper 实例
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
使用 kafka-server-start.sh 启动 kafka 服务
bin/kafka-server-start.sh config/server.properties
创建 topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看 topic 列表，检查是否创建成功
bin/kafka-topics.sh --list --zookeeper localhost:2181
$ test
生产者，发送消息
bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
- 安装 PHP 扩展
git clone https://github.com/edenhill/librdkafka.git
cd librdkafka
./configure
make && make install
直接使用yum安装（推荐）
yum install librdkafka-devel
安装 php-rdkafka 扩展
下载地址：http://pecl.php.net/package/rdkafka
wget rdkafka-6.0.1.tgz
cd rdkafka-6.0.1.tgz
/www/server/php/72/bin/phpize ## 这里根据自己的情况填写路径
./configure --with-php-config=/www/server/php/72/bin/php-config ## 这里根据自己的情况填写路径
make && make install
在 php-ini 加上
extension=rdkafka.so
重启，php-fpm，就应该可以看到该扩展。