From c91f280fc06af39db4895ff554644720f0666bf9 Mon Sep 17 00:00:00 2001 From: Remi Collet Date: Sun, 28 Nov 2021 08:37:49 +0100 Subject: update to 6.0.0RC2 drop patch merged upstream --- REFLECTION | 475 ++++++++++++++++++++++++++++++++++++------------------------- 1 file changed, 278 insertions(+), 197 deletions(-) (limited to 'REFLECTION') diff --git a/REFLECTION b/REFLECTION index 016d951..c0d73e9 100644 --- a/REFLECTION +++ b/REFLECTION @@ -1,4 +1,4 @@ -Extension [ extension #128 rdkafka version 5.0.1 ] { +Extension [ extension #97 rdkafka version 6.0.0RC2 ] { - Constants [184] { Constant [ int RD_KAFKA_CONSUMER ] { 1 } @@ -192,40 +192,47 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { - Parameters [0] { } + - Return [ array ] } Function [ function rd_kafka_err2name ] { - Parameters [1] { - Parameter #0 [ $err ] + Parameter #0 [ int $err ] } + - Return [ ?string ] } Function [ function rd_kafka_err2str ] { - Parameters [1] { - Parameter #0 [ $err ] + Parameter #0 [ int $err ] } + - Return [ ?string ] } Function [ function rd_kafka_errno2err ] { - Parameters [1] { - Parameter #0 [ $errnox ] + Parameter #0 [ int $errnox ] } + - Return [ int ] } Function [ function rd_kafka_errno ] { - Parameters [0] { } + - Return [ int ] } Function [ function rd_kafka_offset_tail ] { - Parameters [1] { - Parameter #0 [ $cnt ] + Parameter #0 [ int $cnt ] } + - Return [ int ] } Function [ function rd_kafka_thread_cnt ] { - Parameters [0] { } + - Return [ int ] } } @@ -242,24 +249,30 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Properties [2] { - Property [ private $error_cb ] - Property [ private $dr_cb ] + Property [ private ?callable $error_cb ] + Property [ private ?callable $dr_cb ] } - - Methods [15] { + - Methods [16] { + Method [ private method __construct ] { + + - Parameters [0] { + } + } + Method [ public method addBrokers ] { - Parameters [1] { - Parameter #0 [ $broker_list ] + Parameter #0 [ string $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } @@ -272,24 +285,24 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method metadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { - Parameter #0 [ $level ] + Parameter #0 [ int $level ] } } Method [ public method newTopic ] { - Parameters [2] { - Parameter #0 [ $topic_name ] - Parameter #1 [ $topic_conf ] + Parameter #0 [ string $topic_name ] + Parameter #1 [ ?RdKafka\Conf $topic_conf = null ] } } @@ -302,61 +315,61 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method poll ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { - Parameter #0 [ $purge_flags ] + Parameter #0 [ int $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { - Parameter #0 [ $logger ] + Parameter #0 [ int $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { - Parameter #0 [ $topic ] - Parameter #1 [ $partition ] - Parameter #2 [ &$low ] - Parameter #3 [ &$high ] - Parameter #4 [ $timeout_ms ] + Parameter #0 [ string $topic ] + Parameter #1 [ int $partition ] + Parameter #2 [ int &$low ] + Parameter #3 [ int &$high ] + Parameter #4 [ int $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { - Parameter #0 [ $topic_partitions ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ array $topic_partitions ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } } @@ -377,10 +390,10 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Methods [17] { - Method [ public method __construct ] { + Method [ public method __construct ] { - Parameters [1] { - Parameter #0 [ $conf ] + Parameter #0 [ ?RdKafka\Conf $conf = null ] } } @@ -393,16 +406,16 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method addBrokers ] { - Parameters [1] { - Parameter #0 [ $broker_list ] + Parameter #0 [ string $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } @@ -415,24 +428,24 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method metadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { - Parameter #0 [ $level ] + Parameter #0 [ int $level ] } } Method [ public method newTopic ] { - Parameters [2] { - Parameter #0 [ $topic_name ] - Parameter #1 [ $topic_conf ] + Parameter #0 [ string $topic_name ] + Parameter #1 [ ?RdKafka\Conf $topic_conf = null ] } } @@ -445,61 +458,61 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method poll ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { - Parameter #0 [ $purge_flags ] + Parameter #0 [ int $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { - Parameter #0 [ $logger ] + Parameter #0 [ int $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { - Parameter #0 [ $topic ] - Parameter #1 [ $partition ] - Parameter #2 [ &$low ] - Parameter #3 [ &$high ] - Parameter #4 [ $timeout_ms ] + Parameter #0 [ string $topic ] + Parameter #1 [ int $partition ] + Parameter #2 [ int &$low ] + Parameter #3 [ int &$high ] + Parameter #4 [ int $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { - Parameter #0 [ $topic_partitions ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ array $topic_partitions ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } } @@ -520,17 +533,17 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Methods [20] { - Method [ public method __construct ] { + Method [ public method __construct ] { - Parameters [1] { - Parameter #0 [ $conf ] + Parameter #0 [ ?RdKafka\Conf $conf = null ] } } Method [ public method initTransactions ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } @@ -543,30 +556,30 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method commitTransaction ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method abortTransaction ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method addBrokers ] { - Parameters [1] { - Parameter #0 [ $broker_list ] + Parameter #0 [ string $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } @@ -579,24 +592,24 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method metadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ ?RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { - Parameter #0 [ $level ] + Parameter #0 [ int $level ] } } Method [ public method newTopic ] { - Parameters [2] { - Parameter #0 [ $topic_name ] - Parameter #1 [ $topic_conf ] + Parameter #0 [ string $topic_name ] + Parameter #1 [ ?RdKafka\Conf $topic_conf = null ] } } @@ -609,67 +622,67 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method poll ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { - Parameter #0 [ $purge_flags ] + Parameter #0 [ int $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { - Parameter #0 [ $logger ] + Parameter #0 [ int $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { - Parameter #0 [ $topic ] - Parameter #1 [ $partition ] - Parameter #2 [ &$low ] - Parameter #3 [ &$high ] - Parameter #4 [ $timeout_ms ] + Parameter #0 [ string $topic ] + Parameter #1 [ int $partition ] + Parameter #2 [ int &$low ] + Parameter #3 [ int &$high ] + Parameter #4 [ int $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { - Parameter #0 [ $topic_partitions ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ array $topic_partitions ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } } } - Class [ class RdKafka\Exception extends Exception implements Throwable ] { + Class [ class RdKafka\Exception extends Exception implements Stringable, Throwable ] { - Constants [0] { } @@ -681,47 +694,81 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Properties [4] { - Property [ protected $message ] - Property [ protected $code ] - Property [ protected $file ] - Property [ protected $line ] + Property [ protected $message = '' ] + Property [ protected $code = 0 ] + Property [ protected $file = NULL ] + Property [ protected $line = NULL ] } - Methods [10] { Method [ public method __construct ] { - Parameters [3] { - Parameter #0 [ $message ] - Parameter #1 [ $code ] - Parameter #2 [ $previous ] + Parameter #0 [ string $message = "" ] + Parameter #1 [ int $code = 0 ] + Parameter #2 [ ?Throwable $previous = null ] } } Method [ public method __wakeup ] { + + - Parameters [0] { + } } Method [ final public method getMessage ] { + + - Parameters [0] { + } + - Return [ string ] } Method [ final public method getCode ] { + + - Parameters [0] { + } } Method [ final public method getFile ] { + + - Parameters [0] { + } + - Return [ string ] } Method [ final public method getLine ] { + + - Parameters [0] { + } + - Return [ int ] } Method [ final public method getTrace ] { + + - Parameters [0] { + } + - Return [ array ] } Method [ final public method getPrevious ] { + + - Parameters [0] { + } + - Return [ ?Throwable ] } Method [ final public method getTraceAsString ] { + + - Parameters [0] { + } + - Return [ string ] } - Method [ public method __toString ] { + Method [ public method __toString ] { + + - Parameters [0] { + } + - Return [ string ] } } } @@ -756,64 +803,64 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method set ] { - Parameters [2] { - Parameter #0 [ $name ] - Parameter #1 [ $value ] + Parameter #0 [ string $name ] + Parameter #1 [ string $value ] } } Method [ public method setDefaultTopicConf ] { - Parameters [1] { - Parameter #0 [ $topic_conf ] + Parameter #0 [ RdKafka\TopicConf $topic_conf ] } } Method [ public method setErrorCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setDrMsgCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setStatsCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setRebalanceCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setConsumeCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setOffsetCommitCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } Method [ public method setLogCb ] { - Parameters [1] { - Parameter #0 [ $callback ] + Parameter #0 [ callable $callback ] } } } @@ -849,21 +896,21 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method set ] { - Parameters [2] { - Parameter #0 [ $name ] - Parameter #1 [ $value ] + Parameter #0 [ string $name ] + Parameter #1 [ string $value ] } } Method [ public method setPartitioner ] { - Parameters [1] { - Parameter #0 [ $partitioner ] + Parameter #0 [ int $partitioner ] } } } } - Class [ class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable ] { + Class [ class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable, Stringable ] { - Constants [0] { } @@ -875,26 +922,26 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Properties [8] { - Property [ protected $message ] - Property [ protected $code ] - Property [ protected $file ] - Property [ protected $line ] - Property [ private $error_string ] - Property [ private $isFatal ] - Property [ private $isRetriable ] - Property [ private $transactionRequiresAbort ] + Property [ protected $message = '' ] + Property [ protected $code = 0 ] + Property [ protected $file = NULL ] + Property [ protected $line = NULL ] + Property [ private string $error_string ] + Property [ private bool $isFatal ] + Property [ private bool $isRetriable ] + Property [ private bool $transactionRequiresAbort ] } - Methods [14] { Method [ public method __construct ] { - Parameters [6] { - Parameter #0 [ $message ] - Parameter #1 [ $code ] - Parameter #2 [ $error_string ] - Parameter #3 [ $isFatal ] - Parameter #4 [ $isRetriable ] - Parameter #5 [ $transactionRequiresAbort ] + Parameter #0 [ string $message ] + Parameter #1 [ int $code ] + Parameter #2 [ string $error_string ] + Parameter #3 [ bool $isFatal ] + Parameter #4 [ bool $isRetriable ] + Parameter #5 [ bool $transactionRequiresAbort ] } } @@ -923,30 +970,64 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } Method [ public method __wakeup ] { + + - Parameters [0] { + } } Method [ final public method getMessage ] { + + - Parameters [0] { + } + - Return [ string ] } Method [ final public method getCode ] { + + - Parameters [0] { + } } Method [ final public method getFile ] { + + - Parameters [0] { + } + - Return [ string ] } Method [ final public method getLine ] { + + - Parameters [0] { + } + - Return [ int ] } Method [ final public method getTrace ] { + + - Parameters [0] { + } + - Return [ array ] } Method [ final public method getPrevious ] { + + - Parameters [0] { + } + - Return [ ?Throwable ] } Method [ final public method getTraceAsString ] { + + - Parameters [0] { + } + - Return [ string ] } - Method [ public method __toString ] { + Method [ public method __toString ] { + + - Parameters [0] { + } + - Return [ string ] } } } @@ -963,23 +1044,23 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Properties [3] { - Property [ private $error_cb ] - Property [ private $rebalance_cb ] - Property [ private $dr_msg_cb ] + Property [ private ?callable $error_cb ] + Property [ private ?callable $rebalance_cb ] + Property [ private ?callable $dr_msg_cb ] } - Methods [18] { Method [ public method __construct ] { - Parameters [1] { - Parameter #0 [ $conf ] + Parameter #0 [ RdKafka\Conf $conf ] } } Method [ public method assign ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ ?array $topic_partitions = null ] } } @@ -992,7 +1073,7 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method commit ] { - Parameters [1] { - Parameter #0 [ $message_or_offsets ] + Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } } @@ -1005,21 +1086,21 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method commitAsync ] { - Parameters [1] { - Parameter #0 [ $message_or_offsets ] + Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } } Method [ public method consume ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } Method [ public method subscribe ] { - Parameters [1] { - Parameter #0 [ $topics ] + Parameter #0 [ array $topics ] } } @@ -1038,65 +1119,65 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method getMetadata ] { - Parameters [3] { - Parameter #0 [ $all_topics ] - Parameter #1 [ $only_topic ] - Parameter #2 [ $timeout_ms ] + Parameter #0 [ bool $all_topics ] + Parameter #1 [ RdKafka\Topic $only_topic ] + Parameter #2 [ int $timeout_ms ] } } Method [ public method newTopic ] { - Parameters [2] { - Parameter #0 [ $topic_name ] - Parameter #1 [ $topic_conf ] + Parameter #0 [ string $topic_name ] + Parameter #1 [ ?RdKafka\Conf $topic_conf = null ] } } Method [ public method getCommittedOffsets ] { - Parameters [2] { - Parameter #0 [ $topic_partitions ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ array $topic_partitions ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method getOffsetPositions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { - Parameter #0 [ $topic ] - Parameter #1 [ $partition ] - Parameter #2 [ &$low ] - Parameter #3 [ &$high ] - Parameter #4 [ $timeout_ms ] + Parameter #0 [ string $topic ] + Parameter #1 [ int $partition ] + Parameter #2 [ int &$low ] + Parameter #3 [ int &$high ] + Parameter #4 [ int $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { - Parameter #0 [ $topic_partitions ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ array $topic_partitions ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { - Parameter #0 [ $topic_partitions ] + Parameter #0 [ array $topic_partitions ] } } } @@ -1114,16 +1195,16 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } - Properties [10] { - Property [ public $err ] - Property [ public $topic_name ] - Property [ public $timestamp ] - Property [ public $partition ] - Property [ public $payload ] - Property [ public $len ] - Property [ public $key ] - Property [ public $offset ] - Property [ public $headers ] - Property [ public $opaque ] + Property [ public int $err ] + Property [ public ?string $topic_name = NULL ] + Property [ public ?int $timestamp = NULL ] + Property [ public int $partition ] + Property [ public ?string $payload = NULL ] + Property [ public ?int $len = NULL ] + Property [ public ?string $key = NULL ] + Property [ public int $offset ] + Property [ public array $headers ] + Property [ public ?string $opaque = NULL ] } - Methods [1] { @@ -1197,13 +1278,13 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { } } - Method [ public method getPartitions ] { + Method [ public method getErr ] { - Parameters [0] { } } - Method [ public method getErr ] { + Method [ public method getPartitions ] { - Parameters [0] { } @@ -1364,9 +1445,9 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method __construct ] { - Parameters [3] { - Parameter #0 [ $topic ] - Parameter #1 [ $partition ] - Parameter #2 [ $offset ] + Parameter #0 [ string $topic ] + Parameter #1 [ int $partition ] + Parameter #2 [ int $offset = 0 ] } } @@ -1379,7 +1460,7 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method setTopic ] { - Parameters [1] { - Parameter #0 [ $topic_name ] + Parameter #0 [ string $topic_name ] } } @@ -1392,7 +1473,7 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method setPartition ] { - Parameters [1] { - Parameter #0 [ $partition ] + Parameter #0 [ int $partition ] } } @@ -1405,7 +1486,7 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method setOffset ] { - Parameters [1] { - Parameter #0 [ $offset ] + Parameter #0 [ int $offset ] } } @@ -1441,7 +1522,7 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method consume ] { - Parameters [1] { - Parameter #0 [ $timeout_ms ] + Parameter #0 [ int $timeout_ms ] } } } @@ -1494,58 +1575,58 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method consumeQueueStart ] { - Parameters [3] { - Parameter #0 [ $partition ] - Parameter #1 [ $offset ] - Parameter #2 [ $queue ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $offset ] + Parameter #2 [ RdKafka\Queue $queue ] } } Method [ public method consumeCallback ] { - Parameters [3] { - Parameter #0 [ $partition ] - Parameter #1 [ $timeout_ms ] - Parameter #2 [ $callback ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $timeout_ms ] + Parameter #2 [ callable $callback ] } } Method [ public method consumeStart ] { - Parameters [2] { - Parameter #0 [ $partition ] - Parameter #1 [ $offset ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $offset ] } } Method [ public method consumeStop ] { - Parameters [1] { - Parameter #0 [ $partition ] + Parameter #0 [ int $partition ] } } Method [ public method consume ] { - Parameters [2] { - Parameter #0 [ $partition ] - Parameter #1 [ $timeout_ms ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $timeout_ms ] } } Method [ public method consumeBatch ] { - Parameters [3] { - Parameter #0 [ $partition ] - Parameter #1 [ $timeout_ms ] - Parameter #2 [ $batch_size ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $timeout_ms ] + Parameter #2 [ int $batch_size ] } } Method [ public method offsetStore ] { - Parameters [2] { - Parameter #0 [ $partition ] - Parameter #1 [ $offset ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $offset ] } } @@ -1581,8 +1662,8 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method offsetStore ] { - Parameters [2] { - Parameter #0 [ $partition ] - Parameter #1 [ $offset ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $offset ] } } @@ -1618,24 +1699,24 @@ Extension [ extension #128 rdkafka version 5.0.1 ] { Method [ public method produce ] { - Parameters [5] { - Parameter #0 [ $partition ] - Parameter #1 [ $msgflags ] - Parameter #2 [ $payload ] - Parameter #3 [ $key ] - Parameter #4 [ $msg_opaque ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $msgflags ] + Parameter #2 [ ?string $payload = null ] + Parameter #3 [ ?string $key = null ] + Parameter #4 [ ?string $msg_opaque = null ] } } Method [ public method producev ] { - Parameters [7] { - Parameter #0 [ $partition ] - Parameter #1 [ $msgflags ] - Parameter #2 [ $payload ] - Parameter #3 [ $key ] - Parameter #4 [ $headers ] - Parameter #5 [ $timestamp_ms ] - Parameter #6 [ $msg_opaque ] + Parameter #0 [ int $partition ] + Parameter #1 [ int $msgflags ] + Parameter #2 [ ?string $payload = null ] + Parameter #3 [ ?string $key = null ] + Parameter #4 [ ?array $headers = null ] + Parameter #5 [ ?int $timestamp_ms = null ] + Parameter #6 [ ?string $msg_opaque = null ] } } -- cgit