Yii3 Queue Adapter for Apache Kafka

Description

Yii3 Queue Adapter for Apache Kafka is adapter in Yii3 Queue Adapters family.

Implementation of adapter is based on synchronous mode of Swoole PHP Kafka client library.

Requirements

• PHP 8.2 or higher.

Installation

The package could be installed with composer:

composer require g41797/queue-kafka

General usage

• As part of Yii3 Queue Framework
• Stand-alone

Configuration

Default configuration:

[
     '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']`
]

Limitations

Job Status

Job Status

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

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

is not supported.

Testing

Unit-testing is supported for local environment. Run of phpunit under GitHib action was disabled because problem of kafka configuration. Description of cumbersome configuration see Kafka Listeners - Explained

License

Yii3 Queue Adapter for Apache Kafka is free software. It is released under the terms of the BSD License. Please see LICENSE for more information.