multividas/kafka-queue

Kafka Queue for PHP

dev-main 2025-04-22 15:54 UTC

Requires

• php: ^8.2
• jobcloud/php-kafka-lib: ^1.0
• laravel/lumen-framework: ^10.0
• squizlabs/php_codesniffer: ^3.7

MIT

• Soulaimane Yahya

README

• https://arnaud-lb.github.io/php-rdkafka-doc/phpdoc/rdkafka.installation.html

installing

composer require multividas/kafka-queue:dev-main --dev

ServiceProvider (KafkaServiceProvider):

• Registers the Kafka queue connector with Laravel's queue manager.

Implements the QueueContract interface.

• Provides methods like push, pop, and size for interacting with Kafka.
• push() pushes a serialized job to Kafka using the producer.
• pop() consumes messages from Kafka and processes jobs.

Connector Class (KafkaConnector):

• Implements the ConnectorInterface.
• Sets up Kafka producer and consumer.