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();