update examples with new conf tweaks

Author: matthewgoslett

examples/KafkaConsumerExample.php

@@ -13,12 +13,17 @@
 $conf->set('metadata.broker.list', $broker);
 $conf->set('enable.auto.commit', 'false');
 $conf->set('offset.store.method', 'broker');
+$conf->set('socket.blocking.max.ms', 50);
 $conf->setDefaultTopicConf($topicConf);
 
 $consumer = new \RdKafka\KafkaConsumer($conf);
 
 // create producer
-$producer = new \RdKafka\Producer();
+$conf = new \RdKafka\Conf();
+$conf->set('socket.blocking.max.ms', 50);
+$conf->set('queue.buffering.max.ms', 20);
+
+$producer = new \RdKafka\Producer($conf);
 $producer->addBrokers($broker);
 
 $adapter = new \Superbalist\PubSub\Kafka\KafkaPubSubAdapter($producer, $consumer);

examples/KafkaPublishExample.php

@@ -13,14 +13,21 @@
 $conf->set('metadata.broker.list', $broker);
 $conf->set('enable.auto.commit', 'false');
 $conf->set('offset.store.method', 'broker');
+$conf->set('socket.blocking.max.ms', 50);
 $conf->setDefaultTopicConf($topicConf);
 
 $consumer = new \RdKafka\KafkaConsumer($conf);
 
 // create producer
-$producer = new \RdKafka\Producer();
+$conf = new \RdKafka\Conf();
+$conf->set('socket.blocking.max.ms', 50);
+$conf->set('queue.buffering.max.ms', 20);
+
+$producer = new \RdKafka\Producer($conf);
 $producer->addBrokers($broker);
 
 $adapter = new \Superbalist\PubSub\Kafka\KafkaPubSubAdapter($producer, $consumer);
 
-$adapter->publish('my_channel', ['hello' => 'world']);
+for ($x = 0; $x < 10; $x++) {
+    $adapter->publish('my_channel', $x);
+}