update stubs for RdKafka

JetBrains · Aug 14, 2021 · a51dd4c · a51dd4c
1 parent 1f1915b
commit a51dd4c
Show file tree

Hide file tree

Showing 6 changed files with 25 additions and 25 deletions.
diff --git a/rdkafka/RdKafka.php b/rdkafka/RdKafka.php
@@ -36,7 +36,7 @@ public function getOutQLen() {}
      *
      * @return Topic
      */
-    public function newTopic($topic_name, ?TopicConf $topic_conf = null) {}
+    public function newTopic($topic_name, $topic_conf = null) {}
 
     /**
      * @param int $timeout_ms
@@ -58,7 +58,7 @@ public function setLogLevel($level) {}
      *
      * @return TopicPartition[]
      */
-    public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {}
+    public function offsetsForTimes($topic_partitions, $timeout_ms) {}
 
     /**
      * @param string $topic
@@ -69,21 +69,21 @@ public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {}
      *
      * @return void
      */
-    public function queryWatermarkOffsets(string $topic, int $partition = 0, int &$low = 0, int &$high = 0, int $timeout_ms = 0) {}
+    public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {}
 
     /**
      * @param int $purge_flags
      *
      * @return int
      */
-    public function purge(int $purge_flags) {}
+    public function purge($purge_flags) {}
 
     /**
      * @param int $timeout_ms
      *
      * @return int
      */
-    public function flush(int $timeout_ms) {}
+    public function flush($timeout_ms) {}
 
     public function metadata($all_topics, $only_topic = false, $timeout_ms = 0) {}
 

diff --git a/rdkafka/RdKafka/Conf.php b/rdkafka/RdKafka/Conf.php
@@ -27,54 +27,54 @@ public function set($name, $value) {}
      *
      * @return void
      */
-    public function setDefaultTopicConf(TopicConf $topic_conf) {}
+    public function setDefaultTopicConf($topic_conf) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setDrMsgCb(callable $callback) {}
+    public function setDrMsgCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setErrorCb(callable $callback) {}
+    public function setErrorCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setRebalanceCb(callable $callback) {}
+    public function setRebalanceCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setStatsCb(callable $callback) {}
+    public function setStatsCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setOffsetCommitCb(callable $callback) {}
+    public function setOffsetCommitCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setConsumeCb(callable $callback) {}
+    public function setConsumeCb($callback) {}
 
     /**
      * @param callable $callback
      *
      * @return void
      */
-    public function setLogCb(callable $callback) {}
+    public function setLogCb($callback) {}
 }
diff --git a/rdkafka/RdKafka/Consumer.php b/rdkafka/RdKafka/Consumer.php
@@ -7,7 +7,7 @@ class Consumer extends \RdKafka
     /**
      * @param null|Conf $conf
      */
-    public function __construct(?Conf $conf = null) {}
+    public function __construct($conf = null) {}
 
     /**
      * @param string    $topic_name

diff --git a/rdkafka/RdKafka/ConsumerTopic.php b/rdkafka/RdKafka/ConsumerTopic.php
@@ -21,7 +21,7 @@ public function consume($partition, $timeout_ms) {}
      *
      * @return void
      */
-    public function consumeQueueStart($partition, $offset, Queue $queue) {}
+    public function consumeQueueStart($partition, $offset, $queue) {}
 
     /**
      * @param int $partition

diff --git a/rdkafka/RdKafka/KafkaConsumer.php b/rdkafka/RdKafka/KafkaConsumer.php
@@ -7,7 +7,7 @@ class KafkaConsumer
     /**
      * @param Conf $conf
      */
-    public function __construct(Conf $conf) {}
+    public function __construct($conf) {}
 
     /**
      * @param TopicPartition[] $topic_partitions
@@ -83,15 +83,15 @@ public function unsubscribe() {}
      *
      * @return array
      */
-    public function getCommittedOffsets(array $topic_partitions, int $timeout_ms) {}
+    public function getCommittedOffsets($topic_partitions, $timeout_ms) {}
 
     /**
      * @param TopicPartition[] $topic_partitions
      * @param int $timeout_ms
      *
      * @return TopicPartition[]
      */
-    public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {}
+    public function offsetsForTimes($topic_partitions, $timeout_ms) {}
 
     /**
      * @param string $topic
@@ -102,20 +102,20 @@ public function offsetsForTimes(array $topic_partitions, int $timeout_ms) {}
      *
      * @return void
      */
-    public function queryWatermarkOffsets(string $topic, int $partition = 0, int &$low = 0, int &$high = 0, int $timeout_ms = 0) {}
+    public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {}
 
     /**
      * @param TopicPartition[] $topic_partitions
      */
-    public function getOffsetPositions(array $topic_partitions) {}
+    public function getOffsetPositions($topic_partitions) {}
 
     /**
      * @param string    $topic_name
      * @param null|TopicConf $topic_conf
      *
      * @return Topic
      */
-    public function newTopic($topic_name, ?TopicConf $topic_conf = null) {}
+    public function newTopic($topic_name, $topic_conf = null) {}
 
     /**
      * @return void

diff --git a/rdkafka/RdKafka/Producer.php b/rdkafka/RdKafka/Producer.php
@@ -7,7 +7,7 @@ class Producer extends \RdKafka
     /**
      * @param null|Conf $conf
      */
-    public function __construct(Conf $conf = null) {}
+    public function __construct($conf = null) {}
 
     /**
      * @param string    $topic_name
@@ -22,7 +22,7 @@ public function newTopic($topic_name, ?TopicConf $topic_conf = null) {}
      *
      * @return void
      */
-    public function initTransactions(int $timeout_ms) {}
+    public function initTransactions($timeout_ms) {}
 
     /**
      * @return void
@@ -34,12 +34,12 @@ public function beginTransaction() {}
      *
      * @return void
      */
-    public function commitTransaction(int $timeout_ms) {}
+    public function commitTransaction($timeout_ms) {}
 
     /**
      * @param int $timeout_ms
      *
      * @return void
      */
-    public function abortTransaction(int $timeout_ms) {}
+    public function abortTransaction($timeout_ms) {}
 }