PHP code example of opennebel / laravel-kafka

1. Go to this page and download the library: Download opennebel/laravel-kafka library. Choose the download type require.

2. Extract the ZIP file and open the index.php.

3. Add this code to the index.php. 
    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

opennebel / laravel-kafka example snippets


use OpenNebel\LaravelKafka\Facades\Kafka;

Kafka::produce('notification-events', 'Hello Kafka!');


$data = [
    'type' => 'email',
    'to' => '[email protected]',
    'subject' => 'Welcome to MondialGP',
    'template' => 'welcome-email',
    'variables' => [
        'name' => 'Jean Dupont',
        'supportEmail' => '[email protected]'
    ]
];

Kafka::produceJson('notification-events', $data);


use OpenNebel\LaravelKafka\KafkaService;

public function handle(KafkaService $kafka)
{
    $kafka->produce('notification-events', 'Message sent via service');
}


return [
    'brokers' => env('KAFKA_BROKERS', 'localhost:9092'),
    'default_topic' => env('KAFKA_DEFAULT_TOPIC', 'notification-events'),
];

bash
php artisan vendor:publish --tag=laravel-kafka-config