From 8ee0d922b6853ad562436c49ca21967e340d5a7b Mon Sep 17 00:00:00 2001 From: Remi Collet Date: Fri, 20 Jan 2023 11:13:10 +0100 Subject: rebuild using remi-librdkafka 2.0.1 --- REFLECTION | 148 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 file changed, 139 insertions(+), 9 deletions(-) (limited to 'REFLECTION') diff --git a/REFLECTION b/REFLECTION index fdfe788..124e729 100644 --- a/REFLECTION +++ b/REFLECTION @@ -1,4 +1,4 @@ -Extension [ extension #118 rdkafka version 6.0.3 ] { +Extension [ extension #120 rdkafka version 6.0.3 ] { - Constants [184] { Constant [ int RD_KAFKA_CONSUMER ] { 1 } @@ -11,8 +11,8 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Constant [ int RD_KAFKA_PURGE_F_QUEUE ] { 1 } Constant [ int RD_KAFKA_PURGE_F_INFLIGHT ] { 2 } Constant [ int RD_KAFKA_PURGE_F_NON_BLOCKING ] { 4 } - Constant [ int RD_KAFKA_VERSION ] { 17367295 } - Constant [ int RD_KAFKA_BUILD_VERSION ] { 17367295 } + Constant [ int RD_KAFKA_VERSION ] { 33554687 } + Constant [ int RD_KAFKA_BUILD_VERSION ] { 33554687 } Constant [ int RD_KAFKA_RESP_ERR__BEGIN ] { -200 } Constant [ int RD_KAFKA_RESP_ERR__BAD_MSG ] { -199 } Constant [ int RD_KAFKA_RESP_ERR__BAD_COMPRESSION ] { -198 } @@ -265,6 +265,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } + - Tentative return [ int ] } Method [ public method getMetadata ] { @@ -274,12 +275,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method metadata ] { @@ -289,6 +292,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { @@ -296,6 +300,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $level ] } + - Tentative return [ void ] } Method [ public method newTopic ] { @@ -304,12 +309,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method poll ] { @@ -317,6 +324,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method flush ] { @@ -324,6 +332,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method purge ] { @@ -331,6 +340,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } + - Tentative return [ int ] } Method [ public method setLogger ] { @@ -338,6 +348,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $logger ] } + - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { @@ -349,6 +360,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method offsetsForTimes ] { @@ -357,6 +369,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ array ] } Method [ public method pausePartitions ] { @@ -364,6 +377,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } Method [ public method resumePartitions ] { @@ -371,6 +385,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -390,7 +405,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { } - Methods [17] { - Method [ public method __construct ] { + Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ ?RdKafka\Conf $conf = null ] @@ -401,6 +416,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ RdKafka\Queue ] } Method [ public method addBrokers ] { @@ -408,6 +424,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } + - Tentative return [ int ] } Method [ public method getMetadata ] { @@ -417,12 +434,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method metadata ] { @@ -432,6 +451,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { @@ -439,6 +459,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $level ] } + - Tentative return [ void ] } Method [ public method newTopic ] { @@ -447,12 +468,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method poll ] { @@ -460,6 +483,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method flush ] { @@ -467,6 +491,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method purge ] { @@ -474,6 +499,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } + - Tentative return [ int ] } Method [ public method setLogger ] { @@ -481,6 +507,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $logger ] } + - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { @@ -492,6 +519,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method offsetsForTimes ] { @@ -500,6 +528,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ array ] } Method [ public method pausePartitions ] { @@ -507,6 +536,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } Method [ public method resumePartitions ] { @@ -514,6 +544,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -533,7 +564,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { } - Methods [20] { - Method [ public method __construct ] { + Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ ?RdKafka\Conf $conf = null ] @@ -545,12 +576,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method beginTransaction ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ public method commitTransaction ] { @@ -558,6 +591,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method abortTransaction ] { @@ -565,6 +599,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method addBrokers ] { @@ -572,6 +607,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } + - Tentative return [ int ] } Method [ public method getMetadata ] { @@ -581,12 +617,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method metadata ] { @@ -596,6 +634,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { @@ -603,6 +642,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $level ] } + - Tentative return [ void ] } Method [ public method newTopic ] { @@ -611,12 +651,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method poll ] { @@ -624,6 +666,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method flush ] { @@ -631,6 +674,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ int ] } Method [ public method purge ] { @@ -638,6 +682,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } + - Tentative return [ int ] } Method [ public method setLogger ] { @@ -645,6 +690,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $logger ] } + - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { @@ -656,6 +702,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method offsetsForTimes ] { @@ -664,6 +711,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ array ] } Method [ public method pausePartitions ] { @@ -671,6 +719,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } Method [ public method resumePartitions ] { @@ -678,6 +727,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -696,8 +746,8 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Properties [4] { Property [ protected $message = '' ] Property [ protected $code = 0 ] - Property [ protected $file = NULL ] - Property [ protected $line = NULL ] + Property [ protected string $file = '' ] + Property [ protected int $line = 0 ] } - Methods [10] { @@ -714,6 +764,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ final public method getMessage ] { @@ -798,6 +849,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ public method set ] { @@ -806,6 +858,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $name ] Parameter #1 [ string $value ] } + - Tentative return [ void ] } Method [ public method setDefaultTopicConf ] { @@ -813,6 +866,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ RdKafka\TopicConf $topic_conf ] } + - Tentative return [ void ] } Method [ public method setErrorCb ] { @@ -820,6 +874,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setDrMsgCb ] { @@ -827,6 +882,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setStatsCb ] { @@ -834,6 +890,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setRebalanceCb ] { @@ -841,6 +898,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setConsumeCb ] { @@ -848,6 +906,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setOffsetCommitCb ] { @@ -855,6 +914,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } Method [ public method setLogCb ] { @@ -862,6 +922,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ callable $callback ] } + - Tentative return [ void ] } } } @@ -891,6 +952,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ public method set ] { @@ -899,6 +961,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $name ] Parameter #1 [ string $value ] } + - Tentative return [ void ] } Method [ public method setPartitioner ] { @@ -906,6 +969,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $partitioner ] } + - Tentative return [ void ] } } } @@ -924,8 +988,8 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Properties [8] { Property [ protected $message = '' ] Property [ protected $code = 0 ] - Property [ protected $file = NULL ] - Property [ protected $line = NULL ] + Property [ protected string $file = '' ] + Property [ protected int $line = 0 ] Property [ private string $error_string ] Property [ private bool $isFatal ] Property [ private bool $isRetriable ] @@ -949,30 +1013,35 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ public method isFatal ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ public method isRetriable ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ public method transactionRequiresAbort ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ public method __wakeup ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ final public method getMessage ] { @@ -1062,12 +1131,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ ?array $topic_partitions = null ] } + - Tentative return [ void ] } Method [ public method getAssignment ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ public method commit ] { @@ -1075,12 +1146,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } + - Tentative return [ void ] } Method [ public method close ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ public method commitAsync ] { @@ -1088,6 +1161,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } + - Tentative return [ void ] } Method [ public method consume ] { @@ -1095,6 +1169,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Message ] } Method [ public method subscribe ] { @@ -1102,18 +1177,21 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topics ] } + - Tentative return [ void ] } Method [ public method getSubscription ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ public method unsubscribe ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ public method getMetadata ] { @@ -1123,6 +1201,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ public method newTopic ] { @@ -1131,6 +1210,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\KafkaConsumerTopic ] } Method [ public method getCommittedOffsets ] { @@ -1139,6 +1219,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ array ] } Method [ public method getOffsetPositions ] { @@ -1146,6 +1227,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } Method [ public method queryWatermarkOffsets ] { @@ -1157,6 +1239,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } + - Tentative return [ void ] } Method [ public method offsetsForTimes ] { @@ -1165,6 +1248,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ array ] } Method [ public method pausePartitions ] { @@ -1172,6 +1256,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } Method [ public method resumePartitions ] { @@ -1179,6 +1264,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -1212,6 +1298,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ ?string ] } } } @@ -1235,24 +1322,28 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getOrigBrokerName ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ public method getBrokers ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } Method [ public method getTopics ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1276,18 +1367,21 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ public method getErr ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getPartitions ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1311,18 +1405,21 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getHost ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ public method getPort ] { - Parameters [0] { } + - Tentative return [ int ] } } } @@ -1346,30 +1443,35 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getErr ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getLeader ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method getReplicas ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } Method [ public method getIsrs ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1393,36 +1495,42 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method current ] { - Parameters [0] { } + - Tentative return [ mixed ] } Method [ public method key ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method next ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ public method rewind ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ public method valid ] { - Parameters [0] { } + - Tentative return [ bool ] } } } @@ -1455,6 +1563,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ ?string ] } Method [ public method setTopic ] { @@ -1462,12 +1571,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ string $topic_name ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getPartition ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method setPartition ] { @@ -1475,12 +1586,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $partition ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getOffset ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ public method setOffset ] { @@ -1488,12 +1601,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $offset ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getErr ] { - Parameters [0] { } + - Tentative return [ ?int ] } } } @@ -1524,6 +1639,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } + - Tentative return [ ?RdKafka\Message ] } } } @@ -1547,6 +1663,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1579,6 +1696,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ int $offset ] Parameter #2 [ RdKafka\Queue $queue ] } + - Tentative return [ void ] } Method [ public method consumeCallback ] { @@ -1588,6 +1706,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ int $timeout_ms ] Parameter #2 [ callable $callback ] } + - Tentative return [ int ] } Method [ public method consumeStart ] { @@ -1596,6 +1715,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } + - Tentative return [ void ] } Method [ public method consumeStop ] { @@ -1603,6 +1723,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { - Parameters [1] { Parameter #0 [ int $partition ] } + - Tentative return [ void ] } Method [ public method consume ] { @@ -1611,6 +1732,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ int $partition ] Parameter #1 [ int $timeout_ms ] } + - Tentative return [ ?RdKafka\Message ] } Method [ public method consumeBatch ] { @@ -1620,6 +1742,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #1 [ int $timeout_ms ] Parameter #2 [ int $batch_size ] } + - Tentative return [ array ] } Method [ public method offsetStore ] { @@ -1628,12 +1751,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } + - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1665,12 +1790,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } + - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1705,6 +1832,7 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #3 [ ?string $key = null ] Parameter #4 [ ?string $msg_opaque = null ] } + - Tentative return [ void ] } Method [ public method producev ] { @@ -1718,12 +1846,14 @@ Extension [ extension #118 rdkafka version 6.0.3 ] { Parameter #5 [ ?int $timestamp_ms = null ] Parameter #6 [ ?string $msg_opaque = null ] } + - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } -- cgit