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.
After configuring all your message options, you must use the send method, to send the message to kafka.
use Junges\Kafka\Facades\Kafka;
/** [@var](https://github.com/var) \Junges\Kafka\Producers\Builder $producer */
$producer = Kafka::publish('broker')
->onTopic('topic')
->withConfigOptions(['key' => 'value'])
->withKafkaKey('kafka-key')
->withHeaders(['header-key' => 'header-value']);
$producer->send();
If you want to send multiple messages, consider using the async producer instead. The default send method is recommended for low-throughput systems only, as it
flushes the producer after every message that is sent.
<x-sponsors.request-sponsor/>
How can I help you explore Laravel packages today?