title | weight |
---|---|
Publishing to kafka |
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 \Junges\Kafka\Producers\ProducerBuilder $producer */
$producer = Kafka::publishOn('topic')
->withConfigOptions(['key' => 'value'])
->withKafkaKey('kafka-key')
->withHeaders(['header-key' => 'header-value']);
$producer->send();