Exemple de partage de l'extension php kafka sous Linux

Cet article partage principalement avec vous des exemples d'extension php de kafka sous Linux, en espérant aider tout le monde.

1. Installez librdkafka

wget https://github.com/edenhill/librdkafka/archive/master.zip #下载
mv master.zip librdkafka-master.zip #修改包名
unzip librdkafka-master.zip #解压
cd librdkafka-master #进入安装文件夹
./configure #配置
make #编译
make install #安装

2. Installez phpkafka

cd /usr/local/src #进入安装包存放目录
wget https://github.com/EVODelavega/phpkafka/archive/master.zip #下载
mv master.zip phpkafka-master.zip #修改包名
unzip phpkafka-master.zip #解压
cd phpkafka-master #进入安装文件夹
/usr/local/php/bin/phpize #加载php扩展模块
./configure --enable-kafka --with-php-config=/usr/local/php/bin/php-config #配置
make #编译
make install #安装
3、修改php配置文件
vi /usr/local/php/etc/php.ini

Ouvrez le fichier de configuration php et ajoutez le code suivant dans la dernière ligne

extension="kafka.so"

:wq! #Enregistrez et quittez

4. Testez le code suivant

et enregistrez-le sous phpinfo.php

<?php
phpinfo();
?>

avec le module kafka

Voici le producteur

$kafka = new Kafka("localhost:9092");
$partitions = $kafka->getPartitionsForTopic('testkk');
$in = fopen('php://stdin', 'r');
while (true) {
    echo "\nEnter comma separated messages:\n";
    $messages = explode(',', fgets($in));
    foreach (array_keys($messages) as $k) {
        //$messages[$k] = trim($messages[$k]);
    }
        $bytes=$kafka->produce("testkk", "kkkkkkk");
    printf("\nSuccessfully sent %d messages (%d bytes)\n\n", count($messages), $bytes);
}

Recommandations associées :

Client Kafka écrit en PHP

Installation et installation de Kafka Kafka-PHP Utilisation des extensions

Assemblage Kafka et utilisation des extensions Kafka-PHP

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!