linwanfeng/kafka-php-sdk

a php client to use kafka,require rdkafka ext

4.0.1 2021-06-05 03:19 UTC

Requires

• php: >=5.5.0

MIT

• lwt

README

composer install

composer require linwanfeng/kafka-php-sdk

composer update

composer update linwanfeng/kafka-php-sdk

Produce by Rdkafka

<?php
use kafkaPhp\KafkaProducer;
use kafkaPhp\KafkaException;
try{
    $kafkaClient = new KafkaProducer('127.0.0.1:9092');
    $kafkaClient->sendMsg('topic', 'msg');
}catch (KafkaException $e){
    echo $e->getErrorMessage();die;
}

Produce by socket

<?php
use kafkaPhp\KafkaSkProducer;
use kafkaPhp\KafkaException;
try{
   $kafkaClient = new KafkaSkProducer('***.***.*.***', '***');
   $response = $kafkaClient->sendMsg('topic', 'msg');
}catch (KafkaException $e){
    echo $e->getErrorMessage();
}

Consumer

<?php
require '../vendor/autoload.php';

use kafkaPhp\KafkaClient;
use kafkaPhp\KafkaException;

try{
    $kafkaClient = new KafkaClient('127.0.0.1:9092', 1000);
    $kafkaClient->initConsumer(['topic1','topic2'], 1);
    while(true){
        $r = $kafkaClient->getMsg(2, 1000);
        ...
    }

}catch (KafkaException $e){
    echo $e->getErrorMessage();die;
}