README

Referência: https://github.com/arnaud-lb/php-rdkafka

PHP Kafka client - php-rdkafka

Referência: https://github.com/arnaud-lb/php-rdkafka

Producer/Examples

<?php

use Barguia\PhpRdkafka\KafkaDispatcher;

$config = array(
    'metadata.broker.list' => 'localhost:9092',
);
$producer = new KafkaDispatcher($config);
$headers = ['index1' => 'value1', 'index2' => 123];
$producer->send('topic_name', 'message', 'key', $headers);

Consumer/Examples

<?php

use Barguia\PhpRdkafka\ConsumerFunction;
use Barguia\PhpRdkafka\KafkaService;


class ClassConsumer implements ConsumerFunction
{
    private KafkaService $consumer;
    public function __construct()
    {
        $config = array(
            'metadata.broker.list' => 'localhost:9092',
        );

        $this->consumer = new KafkaService('CONSUMER_GROUP_SGP_PHP_UNIT', 'SGP_PHP_UNIT', $this, $config);
        # Inicia o consumo do Topic
        $this->consume->run();
    }

    /**
    * @param string $message
    * @param array $headers
    * @return void  
    */
    
    public function consume(string $message, array $headers)
    {
        /**
        * Consome mensagens. O commit é opcional, depende da configuracao 
        */
        echo date('Y-m-d H:i:s ').$message.PHP_EOL;
        var_dump($headers);
        $this->consumer->commit();
    }
}

$consumer = new ClassConsumer();