ci: use optional LIBRDKAFKA_LIBRARY_PATH in examples

Author: dirx

examples/_init.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+use RdKafka\FFI\Library;
+
+// use custom librdkafka library path
+Library::init(
+    Library::VERSION_AUTODETECT,
+    'RdKafka',
+    getenv('LIBRDKAFKA_LIBRARY_PATH') ?: null
+);

examples/binding.php

@@ -5,6 +5,7 @@
 use RdKafka\FFI\Library;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 echo 'has method rd_kafka_conf_new:' . PHP_EOL;
 var_dump(Library::hasMethod('rd_kafka_conf_new'));

examples/consumer-highlevel.php

@@ -6,6 +6,7 @@
 use RdKafka\KafkaConsumer;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $conf = new Conf();
 $conf->set('bootstrap.servers', 'kafka:9092');

examples/consumer-lowlevel.php

@@ -7,6 +7,7 @@
 use RdKafka\TopicConf;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $conf = new Conf();
 $conf->set('bootstrap.servers', 'kafka:9092');
@@ -19,7 +20,7 @@ function (Consumer $consumer, int $level, string $facility, string $message): vo
     }
 );
 
-$conf->set('statistics.interval.ms', (string) 1000);
+$conf->set('statistics.interval.ms', (string)1000);
 $conf->setStatsCb(
     function (Consumer $consumer, string $json, int $jsonLength, $opaque): void {
         echo "stats: ${json}" . PHP_EOL;
@@ -28,7 +29,7 @@ function (Consumer $consumer, string $json, int $jsonLength, $opaque): void {
 
 $topicConf = new TopicConf();
 $topicConf->set('enable.auto.commit', 'true');
-$topicConf->set('auto.commit.interval.ms', (string) 100);
+$topicConf->set('auto.commit.interval.ms', (string)100);
 $topicConf->set('auto.offset.reset', 'earliest');
 var_dump($topicConf->dump());
 

examples/create-topic.php

@@ -7,6 +7,7 @@
 use RdKafka\Conf;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $options = array_merge(
     [
@@ -28,16 +29,16 @@
 $conf = new Conf();
 $conf->set('bootstrap.servers', $options['b']);
 $client = Client::fromConf($conf);
-$client->setWaitForResultEventTimeout((int) $options['w']);
+$client->setWaitForResultEventTimeout((int)$options['w']);
 $partitions = $options['p'];
 $replicationFactor = $options['r'];
 
 $results = $client->createTopics(
     [
         new NewTopic(
-            (string) $options['t'],
-            (int) $partitions,
-            (int) $replicationFactor
+            (string)$options['t'],
+            (int)$partitions,
+            (int)$replicationFactor
         ),
     ]
 );

examples/delete-topic.php

@@ -7,6 +7,7 @@
 use RdKafka\Conf;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $options = array_merge(
     [
@@ -26,12 +27,12 @@
 $conf = new Conf();
 $conf->set('bootstrap.servers', $options['b']);
 $client = Client::fromConf($conf);
-$client->setWaitForResultEventTimeout((int) $options['w']);
+$client->setWaitForResultEventTimeout((int)$options['w']);
 
 $results = $client->deleteTopics(
     [
         new DeleteTopic(
-            (string) $options['t']
+            (string)$options['t']
         ),
     ]
 );

examples/describe-config.php

@@ -7,6 +7,7 @@
 use RdKafka\Conf;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $options = array_merge(
     [
@@ -31,7 +32,7 @@
 
 $results = $client->describeConfigs(
     [
-        new ConfigResource((int) $options['t'], (string) $options['v']),
+        new ConfigResource((int)$options['t'], (string)$options['v']),
     ]
 );
 

examples/metadata.php

@@ -3,9 +3,11 @@
 declare(strict_types=1);
 
 use RdKafka\Conf;
+use RdKafka\FFI\Library;
 use RdKafka\Producer;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $conf = new Conf();
 $conf->set('group.id', 'metadata');

examples/mock-cluster.php

@@ -13,6 +13,7 @@
 use RdKafka\TopicPartition;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $clusterConf = new Conf();
 $clusterConf->set('log_level', (string) LOG_DEBUG);

examples/offset-lags.php

@@ -37,6 +37,8 @@
 $composerLoader = require_once dirname(__DIR__) . '/vendor/autoload.php';
 $composerLoader->addPsr4('RdKafka\\Examples\\', __DIR__);
 
+include '_init.php';
+
 $conf = new Conf();
 $conf->set('bootstrap.servers', 'kafka:9092');
 $conf->set('group.id', 'consumer-offsets.dev');