Laravel Kafka Laravel Package

title: Publishing to kafka weight: 5

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/>