greensight/laravel-phprdkafka-producer

此包已被弃用且不再维护。作者建议使用 ensi/laravel-phprdkafka-producer 包。

laravel-phprdkafka 的高级意见化生产者

维护者

详细信息

github.com/greensight/laravel-php-rdkafka-producer

主页

源代码

问题

安装: 86

依赖者: 0

建议者: 0

安全: 0

星标: 1

关注者: 0

分支: 0

开放问题: 0

语言:Shell

0.1.0 2021-10-01 07:37 UTC

Requires

Requires (Dev)

MIT b7c340d0d2ff5c85595b8e78913ef7f2655ebde2

  • arrilot <nekrasov.woop@greensight.ru>

laravelkafkagreensight

This package is auto-updated.

Last update: 2021-10-05 19:55:08 UTC

README

已弃用，请使用 https://github.com/ensi-platform/laravel-php-rdkafka-producer 代替

laravel-phprdkafka 的高级意见化生产者 greensight/laravel-phprdkafka

安装

首先，您需要安装和配置 greensight/laravel-phprdkafka

然后，

composer require greensight/laravel-phprdkafka-producer

使用方法

发送单个消息

use Greensight\LaravelPhpRdKafkaProducer\HighLevelProducer;

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

一次性发送多个消息

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

所有默认选项

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) {
    //...
}

测试

composer test

变更日志

请参阅 CHANGELOG 以获取最近更改的更多信息。

许可证

MIT 许可证 (MIT)。请参阅 许可证文件 以获取更多信息。