README

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.