mateusjunges/laravel-kafka
Laravel Kafka makes it easy to produce and consume Kafka messages in Laravel with a clean, expressive API and improved testability. Build producers and consumers quickly, integrate with your app workflows, and avoid painful Kafka testing setups.
If your application needs to read messages from a Kafka topic, you must create a consumer object, subscribe to the appropriate topic and start receiving messages.
To create a consumer using this package you can use the consumer method, on Kafka facade:
use Junges\Kafka\Facades\Kafka;
$consumer = Kafka::consumer();
This method also allows you to specify the topics it should consume, the broker and the consumer group id:
use Junges\Kafka\Facades\Kafka;
$consumer = Kafka::consumer(['topic-1', 'topic-2'], 'group-id', 'broker');
This method returns a Junges\Kafka\Consumers\ConsumerBuilder::class instance, and you can use it to configure your consumer.
<x-sponsors.request-sponsor/>
How can I help you explore Laravel packages today?