ci: use optional LIBRDKAFKA_LIBRARY_PATH in examples

idealo · Oct 28, 2024 · d5aebf8 · d5aebf8
1 parent d2576c2
commit d5aebf8
Show file tree

Hide file tree

Showing 13 changed files with 44 additions and 11 deletions.
diff --git a/examples/_init.php b/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
+);
diff --git a/examples/binding.php b/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'));

diff --git a/examples/consumer-highlevel.php b/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');

diff --git a/examples/consumer-lowlevel.php b/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());
 

diff --git a/examples/create-topic.php b/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
         ),
     ]
 );

diff --git a/examples/delete-topic.php b/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']
         ),
     ]
 );

diff --git a/examples/describe-config.php b/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']),
     ]
 );
 

diff --git a/examples/metadata.php b/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');

diff --git a/examples/mock-cluster.php b/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);

diff --git a/examples/offset-lags.php b/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');

diff --git a/examples/preload.php b/examples/preload.php
@@ -5,6 +5,7 @@
 use RdKafka\FFI\Library;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $files = new RegexIterator(
     new RecursiveIteratorIterator(
@@ -22,4 +23,8 @@
     require_once($file->getPathName());
 }
 
-Library::preload();
+Library::preload(
+    Library::VERSION_AUTODETECT,
+    'RdKafka',
+    getenv('LIBRDKAFKA_LIBRARY_PATH') ?? null
+);
diff --git a/examples/producer.php b/examples/producer.php
@@ -8,6 +8,7 @@
 use RdKafka\TopicConf;
 
 require_once dirname(__DIR__) . '/vendor/autoload.php';
+include '_init.php';
 
 $conf = new Conf();
 $conf->set('bootstrap.servers', 'kafka:9092');

diff --git a/examples/version.php b/examples/version.php
@@ -9,7 +9,11 @@
 $version = getenv('LIBRDKAFKA_VERSION') ?: '';
 $version = ltrim($version, 'v');
 $version = $version === 'master' ? Library::VERSION_LATEST : $version;
-Library::init($version);
+Library::init(
+    $version,
+    'RdKafka',
+    getenv('LIBRDKAFKA_LIBRARY_PATH') ?: null
+);
 
 echo 'Binding version (string)    : ' . Library::getVersion() . PHP_EOL;
 echo 'librdkafka version (int)    : ' . Library::rd_kafka_version() . PHP_EOL;