g41797/queue-kafka

Apache Kafka 的 Yii 队列适配器

维护者

详细信息

github.com/g41797/queue-kafka

源代码

问题

安装: 0

依赖项: 0

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 0

开放问题: 1

v0.0.3 2024-07-10 06:21 UTC

Requires

Requires (Dev)

BSD-3-Clause daa2e4f0ee94d51e71a99c82b4bb2d36a5f51d51

queuekafkayii3

This package is auto-updated.

Last update: 2024-09-10 07:19:58 UTC

README

build

描述

Yii3 Queue Adapter for Apache Kafka 是 Yii3 队列适配器家族 的一部分。

适配器的实现基于 Swoole PHP Kafka 客户端 库的同步模式。

要求

  • PHP 8.2 或更高版本。

安装

可以通过 composer 安装此包

composer require g41797/queue-kafka

通用用法

配置

默认配置

[
     'bootstrapServers' => 'localhost:9092',  // Format `'127.0.0.1:9092,127.0.0.1:9093'` or `['127.0.0.1:9092','127.0.0.1:9093']`
]

限制

作业状态

作业状态

// Push a job into the queue and get a message ID.
$id = $queue->push(new SomeJob());

// Get job status.
$status = $queue->status($id);

不支持。

测试

支持本地环境的单元测试。由于 Kafka 配置问题，GitHib 行动下的 phpunit 运行已被禁用。关于繁琐配置的描述，请参阅 Kafka Listeners - Explained

许可证

Yii3 Queue Adapter for Apache Kafka 是自由软件。它根据 BSD 许可证的条款发布。有关更多信息，请参阅 LICENSE。