diff options
Diffstat (limited to 'REFLECTION')
| -rw-r--r-- | REFLECTION | 151 |
1 files changed, 141 insertions, 10 deletions
@@ -1,6 +1,6 @@ -Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { +Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - - Constants [184] { + - Constants [185] { Constant [ int RD_KAFKA_CONSUMER ] { 1 } Constant [ int RD_KAFKA_OFFSET_BEGINNING ] { -2 } Constant [ int RD_KAFKA_OFFSET_END ] { -1 } @@ -11,8 +11,8 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { 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 ] { 17302271 } + Constant [ int RD_KAFKA_VERSION ] { 33685759 } + 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 } @@ -74,6 +74,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Constant [ int RD_KAFKA_RESP_ERR__ASSIGNMENT_LOST ] { -142 } Constant [ int RD_KAFKA_RESP_ERR__NOOP ] { -141 } Constant [ int RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET ] { -140 } + Constant [ int RD_KAFKA_RESP_ERR__LOG_TRUNCATION ] { -139 } Constant [ int RD_KAFKA_RESP_ERR__END ] { -100 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN ] { -1 } Constant [ int RD_KAFKA_RESP_ERR_NO_ERROR ] { 0 } @@ -265,6 +266,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> string $broker_list ] } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getMetadata ] { @@ -274,12 +276,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal:rdkafka> public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka> public method metadata ] { @@ -289,6 +293,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal, deprecated:rdkafka> public method setLogLevel ] { @@ -296,6 +301,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $level ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method newTopic ] { @@ -304,12 +310,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $topic_name ] Parameter #1 [ <optional> ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ <internal, deprecated:rdkafka> public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method poll ] { @@ -317,6 +325,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method flush ] { @@ -324,6 +333,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method purge ] { @@ -331,6 +341,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $purge_flags ] } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka> public method setLogger ] { @@ -338,6 +349,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $logger ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method queryWatermarkOffsets ] { @@ -349,6 +361,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #3 [ <required> int &$high ] Parameter #4 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method offsetsForTimes ] { @@ -357,6 +370,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> array $topic_partitions ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method pausePartitions ] { @@ -364,6 +378,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method resumePartitions ] { @@ -371,6 +386,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -390,7 +406,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { } - Methods [17] { - Method [ <internal:rdkafka, overwrites RdKafka, ctor> public method __construct ] { + Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { Parameter #0 [ <optional> ?RdKafka\Conf $conf = null ] @@ -401,6 +417,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ RdKafka\Queue ] } Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] { @@ -408,6 +425,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> string $broker_list ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] { @@ -417,12 +435,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] { @@ -432,6 +452,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] { @@ -439,6 +460,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $level ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] { @@ -447,12 +469,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $topic_name ] Parameter #1 [ <optional> ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method poll ] { @@ -460,6 +484,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method flush ] { @@ -467,6 +492,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method purge ] { @@ -474,6 +500,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $purge_flags ] } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] { @@ -481,6 +508,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $logger ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] { @@ -492,6 +520,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #3 [ <required> int &$high ] Parameter #4 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] { @@ -500,6 +529,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> array $topic_partitions ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ array ] } Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] { @@ -507,6 +537,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] { @@ -514,6 +545,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -533,7 +565,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { } - Methods [20] { - Method [ <internal:rdkafka, overwrites RdKafka, ctor> public method __construct ] { + Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { Parameter #0 [ <optional> ?RdKafka\Conf $conf = null ] @@ -545,12 +577,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method beginTransaction ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method commitTransaction ] { @@ -558,6 +592,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method abortTransaction ] { @@ -565,6 +600,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] { @@ -572,6 +608,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> string $broker_list ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] { @@ -581,12 +618,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] { @@ -596,6 +635,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] { @@ -603,6 +643,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $level ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] { @@ -611,12 +652,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $topic_name ] Parameter #1 [ <optional> ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\Topic ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method poll ] { @@ -624,6 +667,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method flush ] { @@ -631,6 +675,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ int ] } Method [ <internal:rdkafka, inherits RdKafka> public method purge ] { @@ -638,6 +683,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $purge_flags ] } + - Tentative return [ int ] } Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] { @@ -645,6 +691,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $logger ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] { @@ -656,6 +703,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #3 [ <required> int &$high ] Parameter #4 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] { @@ -664,6 +712,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> array $topic_partitions ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ array ] } Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] { @@ -671,6 +720,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] { @@ -678,6 +728,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -696,8 +747,8 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - 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 +765,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] { @@ -798,6 +850,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method set ] { @@ -806,6 +859,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $name ] Parameter #1 [ <required> string $value ] } + - Tentative return [ void ] } Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] { @@ -813,6 +867,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> RdKafka\TopicConf $topic_conf ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setErrorCb ] { @@ -820,6 +875,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setDrMsgCb ] { @@ -827,6 +883,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setStatsCb ] { @@ -834,6 +891,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setRebalanceCb ] { @@ -841,6 +899,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setConsumeCb ] { @@ -848,6 +907,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setOffsetCommitCb ] { @@ -855,6 +915,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setLogCb ] { @@ -862,6 +923,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> callable $callback ] } + - Tentative return [ void ] } } } @@ -891,6 +953,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method set ] { @@ -899,6 +962,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $name ] Parameter #1 [ <required> string $value ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method setPartitioner ] { @@ -906,6 +970,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $partitioner ] } + - Tentative return [ void ] } } } @@ -924,8 +989,8 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - 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 +1014,35 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ <internal:rdkafka> public method isFatal ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ <internal:rdkafka> public method isRetriable ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ <internal:rdkafka> public method transactionRequiresAbort ] { - Parameters [0] { } + - Tentative return [ bool ] } Method [ <internal:Core, inherits Exception> public method __wakeup ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] { @@ -1062,12 +1132,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <optional> ?array $topic_partitions = null ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method getAssignment ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method commit ] { @@ -1075,12 +1147,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <optional> RdKafka\Message|array|null $message_or_offsets = null ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method close ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method commitAsync ] { @@ -1088,6 +1162,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <optional> RdKafka\Message|array|null $message_or_offsets = null ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method consume ] { @@ -1095,6 +1170,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Message ] } Method [ <internal:rdkafka> public method subscribe ] { @@ -1102,18 +1178,21 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topics ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method getSubscription ] { - Parameters [0] { } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method unsubscribe ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method getMetadata ] { @@ -1123,6 +1202,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> ?RdKafka\Topic $only_topic ] Parameter #2 [ <required> int $timeout_ms ] } + - Tentative return [ RdKafka\Metadata ] } Method [ <internal:rdkafka> public method newTopic ] { @@ -1131,6 +1211,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> string $topic_name ] Parameter #1 [ <optional> ?RdKafka\TopicConf $topic_conf = null ] } + - Tentative return [ RdKafka\KafkaConsumerTopic ] } Method [ <internal:rdkafka> public method getCommittedOffsets ] { @@ -1139,6 +1220,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> array $topic_partitions ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method getOffsetPositions ] { @@ -1146,6 +1228,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method queryWatermarkOffsets ] { @@ -1157,6 +1240,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #3 [ <required> int &$high ] Parameter #4 [ <required> int $timeout_ms ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method offsetsForTimes ] { @@ -1165,6 +1249,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> array $topic_partitions ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method pausePartitions ] { @@ -1172,6 +1257,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method resumePartitions ] { @@ -1179,6 +1265,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> array $topic_partitions ] } + - Tentative return [ array ] } } } @@ -1212,6 +1299,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ ?string ] } } } @@ -1235,24 +1323,28 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getOrigBrokerName ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ <internal:rdkafka> public method getBrokers ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } Method [ <internal:rdkafka> public method getTopics ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1276,18 +1368,21 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ <internal:rdkafka> public method getErr ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getPartitions ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1311,18 +1406,21 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getHost ] { - Parameters [0] { } + - Tentative return [ string ] } Method [ <internal:rdkafka> public method getPort ] { - Parameters [0] { } + - Tentative return [ int ] } } } @@ -1346,30 +1444,35 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getErr ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getLeader ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method getReplicas ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } Method [ <internal:rdkafka> public method getIsrs ] { - Parameters [0] { } + - Tentative return [ RdKafka\Metadata\Collection ] } } } @@ -1393,36 +1496,42 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka, prototype Iterator> public method current ] { - Parameters [0] { } + - Tentative return [ mixed ] } Method [ <internal:rdkafka, prototype Iterator> public method key ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka, prototype Iterator> public method next ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:rdkafka, prototype Iterator> public method rewind ] { - Parameters [0] { } + - Tentative return [ void ] } Method [ <internal:rdkafka, prototype Iterator> public method valid ] { - Parameters [0] { } + - Tentative return [ bool ] } } } @@ -1455,6 +1564,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ ?string ] } Method [ <internal:rdkafka> public method setTopic ] { @@ -1462,12 +1572,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> string $topic_name ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ <internal:rdkafka> public method getPartition ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method setPartition ] { @@ -1475,12 +1587,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $partition ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ <internal:rdkafka> public method getOffset ] { - Parameters [0] { } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method setOffset ] { @@ -1488,12 +1602,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $offset ] } + - Tentative return [ RdKafka\TopicPartition ] } Method [ <internal:rdkafka> public method getErr ] { - Parameters [0] { } + - Tentative return [ ?int ] } } } @@ -1524,6 +1640,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $timeout_ms ] } + - Tentative return [ ?RdKafka\Message ] } } } @@ -1547,6 +1664,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1579,6 +1697,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> int $offset ] Parameter #2 [ <required> RdKafka\Queue $queue ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method consumeCallback ] { @@ -1588,6 +1707,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> int $timeout_ms ] Parameter #2 [ <required> callable $callback ] } + - Tentative return [ int ] } Method [ <internal:rdkafka> public method consumeStart ] { @@ -1596,6 +1716,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> int $partition ] Parameter #1 [ <required> int $offset ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method consumeStop ] { @@ -1603,6 +1724,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { - Parameters [1] { Parameter #0 [ <required> int $partition ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method consume ] { @@ -1611,6 +1733,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> int $partition ] Parameter #1 [ <required> int $timeout_ms ] } + - Tentative return [ ?RdKafka\Message ] } Method [ <internal:rdkafka> public method consumeBatch ] { @@ -1620,6 +1743,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #1 [ <required> int $timeout_ms ] Parameter #2 [ <required> int $batch_size ] } + - Tentative return [ array ] } Method [ <internal:rdkafka> public method offsetStore ] { @@ -1628,12 +1752,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> int $partition ] Parameter #1 [ <required> int $offset ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1665,12 +1791,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #0 [ <required> int $partition ] Parameter #1 [ <required> int $offset ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } @@ -1705,6 +1833,7 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #3 [ <optional> ?string $key = null ] Parameter #4 [ <optional> ?string $msg_opaque = null ] } + - Tentative return [ void ] } Method [ <internal:rdkafka> public method producev ] { @@ -1718,12 +1847,14 @@ Extension [ <persistent> extension #95 rdkafka version 6.0.2 ] { Parameter #5 [ <optional> ?int $timestamp_ms = null ] Parameter #6 [ <optional> ?string $msg_opaque = null ] } + - Tentative return [ void ] } Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { - Parameters [0] { } + - Tentative return [ string ] } } } |