PHP code example of m6web / kafka-bundle

1. Go to this page and download the library: Download m6web/kafka-bundle 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/ */

m6web / kafka-bundle example snippets


// app/AppKernel.php

public function registerBundles()
{
    $bundles = array(
        new M6Web\Bundle\KafkaBundle\M6WebKafkaBundle(),
    );
}


$producer->produce('message', RD_KAFKA_PARTITION_UA, '12345');


$consumer->consume();


$consumer->consume(false);


$consumer->commit();