chore: check if native partitioner is available

Author: dirx

src/RdKafka/TopicConf.php

@@ -40,7 +40,7 @@ public function dump(): array
     {
         $count = Library::new('size_t');
         $dump = Library::rd_kafka_topic_conf_dump($this->topicConf, FFI::addr($count));
-        $count = (int) $count->cdata;
+        $count = (int)$count->cdata;
 
         $result = [];
         for ($i = 0; $i < $count; $i += 2) {
@@ -106,12 +106,14 @@ public function setPartitioner(int $partitioner): void
                 break;
 
             default:
-                throw new InvalidArgumentException('Invalid partitioner');
-                break;
+                throw new InvalidArgumentException('Invalid partitioner given');
         }
 
+        Library::requireMethod($partitionerMethod);
+
         Library::rd_kafka_topic_conf_set_partitioner_cb(
             $this->topicConf,
+            // todo: replace with Library::getFFI()->$partitionerMethod when dropping php < 8.1
             NativePartitionerCallbackProxy::create($partitionerMethod)
         );
     }

tests/RdKafka/TopicConfTest.php

@@ -7,6 +7,7 @@
 use ConsumeTrait;
 use InvalidArgumentException;
 use PHPUnit\Framework\TestCase;
+use RequireVersionTrait;
 
 /**
  * @covers \RdKafka\TopicConf
@@ -16,6 +17,7 @@
  */
 class TopicConfTest extends TestCase
 {
+    use RequireVersionTrait;
     use ConsumeTrait;
 
     public function testDump(): void
@@ -119,6 +121,17 @@ public function testSetPartitionerWithUnknownId(): void
         $conf->setPartitioner(9999);
     }
 
+    public function testSetPartitionerWithUnsupportedTypeShouldFail(): void
+    {
+        $this->requiresLibrdkafkaVersion('<', '1.4.0');
+
+        $conf = new TopicConf();
+
+        $this->expectException(\RuntimeException::class);
+        $this->expectExceptionMessageMatches('/rd_kafka_msg_partitioner_fnv1a_random/');
+        $conf->setPartitioner(RD_KAFKA_MSG_PARTITIONER_FNV1A);
+    }
+
     /**
      * @group ffiOnly
      */
@@ -170,7 +183,11 @@ public function testSetPartitionerCbWithCallback(): void
         $topicConf = new TopicConf();
         $topicConf->setOpaque($expectedTopicOpaque);
         $topicConf->setPartitionerCb(
-            function (?string $key, int $partitionCount, ?object $topic_opaque = null, ?object $message_opaque = null) use (&$callbackTopicOpaque, &$callbackMessageOpaque) {
+            function (?string $key, int $partitionCount, ?object $topic_opaque = null, ?object $message_opaque = null) use (
+                &
+                $callbackTopicOpaque,
+                &$callbackMessageOpaque
+            ) {
                 $callbackTopicOpaque = $topic_opaque;
                 $callbackMessageOpaque = $message_opaque;
                 // force partition 2