greensight/laravel-phprdkafka-producer

This package is abandoned and no longer maintained. The author suggests using the ensi/laravel-phprdkafka-producer package instead.

Opiniated High Level producer for laravel-phprdkafka

0.1.0 2021-10-01 07:37 UTC

Requires

• php: ^8.0
• ext-rdkafka: *
• greensight/laravel-phprdkafka: ^0.1.4

Requires (Dev)

• brianium/paratest: ^6.2
• nunomaduro/collision: ^5.3
• orchestra/testbench: ^6.15
• phpunit/phpunit: ^9.3
• spatie/laravel-ray: ^1.9

MIT

• arrilot

• laravel
• kafka
• greensight

README

Deprecated, use https://github.com/ensi-platform/laravel-php-rdkafka-producer instead

Opiniated High Level producer for greensight/laravel-phprdkafka

Installation

Firstly, you have to install and configure greensight/laravel-phprdkafka

Then,

composer require greensight/laravel-phprdkafka-producer

Usage

Send a single message:

use Greensight\LaravelPhpRdKafkaProducer\HighLevelProducer;

(new HighLevelProducer($topicName))->sendOne($messageString);

Send several messages at once:

(new HighLevelProducer($topicName))->sendMany([$message1String, $message2String]);

All options with defaults:

use Greensight\LaravelPhpRdKafkaProducer\HighLevelProducer;
use Greensight\LaravelPhpRdKafkaProducer\Exceptions\KafkaProducerException;

$producer = new HighLevelProducer(
    topicName: $topicName, 
    producerName: 'some-producer-from-greensight/laravel-phprdkafka-config', 
    flushTimeout: 5000, // ms
    flushRetries: 5,
);

try {
    $producer
        ->setFlushTimeout(10000)
        ->setFlushRetries(10)
        ->sendOne($messageString);
} catch (KafkaProducerException $e) {
    //...
}

Testing

composer test

Changelog

Please see CHANGELOG for more information on what has changed recently.

License

The MIT License (MIT). Please see License File for more information.