This is the documentation for v1.8 but the latest version is v1.13 . You can switch versions in the menu on the left/at the top. Check your current version with the following command:


                                composer show mateusjunges/laravel-kafka

Publishing to kafka

After configuring all your message options, you must use the send method, to send the message to kafka.

use Junges\Kafka\Facades\Kafka;

/** @var \Junges\Kafka\Producers\ProducerBuilder $producer */
$producer = Kafka::publishOn('topic')
    ->withConfigOptions(['key' => 'value'])
    ->withKafkaKey('kafka-key')
    ->withHeaders(['header-key' => 'header-value']);

$producer->send();