0.2.0

Author: danikdantist

composer.json

@@ -1,6 +1,6 @@
 {
   "name": "danikdantist/queue-wrapper",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "My first Composer project",
   "keywords": [
     "queue",

src/Drivers/Kafka/Producer.php

@@ -53,10 +53,12 @@ protected function init()
         $conf->set('queue.buffering.max.messages',10000000);
 
         $conf->setErrorCb(function ($kafka, $err, $reason) {
+            $this->logError('broker-list: '.implode(',', $this->config->getBrokerList()));
             $this->logError(sprintf("%s (reason: %s)\n", rd_kafka_err2str($err), $reason));
         });
         //$conf->setLogLevel((string) LOG_DEBUG);
         //$conf->set('debug', 'all');
+        $conf->set('bootstrap.servers', implode(',', $this->config->getBrokerList()));
         $rk = new \RdKafka\Producer($conf);
 
         $rk->addBrokers(implode(',', $this->config->getBrokerList()));