multividas / kafka-queue
Kafka Queue for PHP
dev-main
2025-04-16 22:50 UTC
Requires
- php: ^8.2
- jobcloud/php-kafka-lib: ^1.0
- laravel/lumen-framework: ^10.0
- squizlabs/php_codesniffer: ^3.7
This package is not auto-updated.
Last update: 2025-04-16 23:17:20 UTC
README
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.