summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--PHPINFO8
-rw-r--r--REFLECTION151
-rw-r--r--php-pecl-rdkafka6.spec115
3 files changed, 219 insertions, 55 deletions
diff --git a/PHPINFO b/PHPINFO
index c86a611..6e19a1d 100644
--- a/PHPINFO
+++ b/PHPINFO
@@ -2,7 +2,7 @@
rdkafka
rdkafka support => enabled
-version => 6.0.2
-build date => Jun 13 2022 00:00:00
-librdkafka version (runtime) => 1.9.0
-librdkafka version (build) => 1.8.2.255
+version => 6.0.3
+build date => Jan 19 2023 00:00:00
+librdkafka version (runtime) => 2.2.0
+librdkafka version (build) => 2.0.0.255
diff --git a/REFLECTION b/REFLECTION
index 98c0f86..a7d9798 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -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 ]
}
}
}
diff --git a/php-pecl-rdkafka6.spec b/php-pecl-rdkafka6.spec
index 99f38b5..18c157f 100644
--- a/php-pecl-rdkafka6.spec
+++ b/php-pecl-rdkafka6.spec
@@ -1,14 +1,17 @@
# remirepo/fedora spec file for php-pecl-rdkafka6
#
-# Copyright (c) 2015-2022 Remi Collet
-# License: CC-BY-SA
+# Copyright (c) 2015-2023 Remi Collet
+# License: CC-BY-SA-4.0
# http://creativecommons.org/licenses/by-sa/4.0/
#
# Please, preserve the changelog entries
#
+
+# use library installed in /opt
+%bcond_without move_to_opt
+
%if 0%{?scl:1}
-%global sub_prefix %{scl_prefix}
-%scl_package php-pecl-rdkafka
+%scl_package php-pecl-rdkafka6
%endif
%global with_zts 0%{!?_without_zts:%{?__ztsphp:1}}
@@ -16,38 +19,47 @@
%global with_tests %{?_without_tests:0}%{!?_without_tests:1}
%global ini_name 40-%{pecl_name}.ini
+%if %{with move_to_opt}
+# Disable RPATH check
+%global __arch_install_post /bin/true
+%global __brp_check_rpaths /bin/true
+
+%global buildver %(PKG_CONFIG_PATH=/opt/%{?vendeur:%{vendeur}/}librdkafka/%{_lib}/pkgconfig pkg-config --silence-errors --modversion rdkafka 2>/dev/null || echo 65536)
+%else
%global buildver %(pkg-config --silence-errors --modversion rdkafka 2>/dev/null || echo 65536)
+%endif
-%global upstream_version 6.0.2
+%global upstream_version 6.0.3
#global upstream_prever RC2
+%global sources %{pecl_name}-%{upstream_version}%{?upstream_prever}
+%global _configure ../%{sources}/configure
Summary: Kafka client based on librdkafka
-Name: %{?sub_prefix}php-pecl-%{pecl_name}6
+Name: %{?scl_prefix}php-pecl-%{pecl_name}6
Version: %{upstream_version}%{?upstream_prever:~%{upstream_prever}}
-Release: 1%{?dist}%{!?scl:%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')}}
+Release: 4%{?dist}%{!?scl:%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')}}
License: MIT
URL: https://pecl.php.net/package/%{pecl_name}
Source0: https://pecl.php.net/get/%{pecl_name}-%{upstream_version}%{?upstream_prever}.tgz
BuildRequires: make
BuildRequires: %{?dtsprefix}gcc
-BuildRequires: librdkafka1php-devel >= 1.6
+%if %{with move_to_opt}
+BuildRequires: %{?vendeur:%{vendeur}-}librdkafka-devel >= 2.2
+Requires: %{?vendeur:%{vendeur}-}librdkafka%{?_isa} >= %{buildver}
+%else
+BuildRequires: librdkafka-devel >= 1.4
+%endif
BuildRequires: %{?scl_prefix}php-devel >= 7.0
BuildRequires: %{?scl_prefix}php-pear
Requires: %{?scl_prefix}php(zend-abi) = %{php_zend_api}
Requires: %{?scl_prefix}php(api) = %{php_core_api}
-%{?_sclreq:Requires: %{?scl_prefix}runtime%{?_sclreq}%{?_isa}}
-Requires: librdkafka1php%{?_isa} >= %{buildver}
Provides: %{?scl_prefix}php-%{pecl_name} = %{version}
Provides: %{?scl_prefix}php-%{pecl_name}%{?_isa} = %{version}
Provides: %{?scl_prefix}php-pecl(%{pecl_name}) = %{version}
Provides: %{?scl_prefix}php-pecl(%{pecl_name})%{?_isa} = %{version}
-%if "%{?scl_prefix}" != "%{?sub_prefix}"
-Provides: %{?scl_prefix}php-pecl-%{pecl_name} = %{version}-%{release}
-Provides: %{?scl_prefix}php-pecl-%{pecl_name}%{?_isa} = %{version}-%{release}
-%endif
%if 0%{?fedora} >= 36 || 0%{?rhel} >= 9 || "%{php_version}" >= "8.1"
Obsoletes: %{?scl_prefix}php-pecl-%{pecl_name} < 5
@@ -64,18 +76,10 @@ Obsoletes: %{?scl_prefix}php-pecl-%{pecl_name}4 < 5
Provides: %{?scl_prefix}php-pecl-%{pecl_name}4 = %{version}-%{release}
Provides: %{?scl_prefix}php-pecl-%{pecl_name}4%{?_isa} = %{version}-%{release}
-%if "%{?packager}" == "Remi Collet" && 0%{!?scl:1} && 0%{?rhel}
-# Other third party repo stuff
-%if "%{php_version}" > "7.4"
-Obsoletes: php74-pecl-%{pecl_name} <= %{version}
-%endif
-%if "%{php_version}" > "8.0"
-Obsoletes: php80-pecl-%{pecl_name} <= %{version}
-%endif
-%if "%{php_version}" > "8.1"
-Obsoletes: php81-pecl-%{pecl_name} <= %{version}
-%endif
+%if %{with move_to_opt}
+%{?filter_requires_in: %filter_requires_in %{_libdir}/.*\.so$}
%endif
+%{?filter_setup}
%description
@@ -86,14 +90,13 @@ Package built for PHP %(%{__php} -r 'echo PHP_MAJOR_VERSION.".".PHP_MINOR_VERSIO
%prep
%setup -q -c
-mv %{pecl_name}-%{upstream_version}%{?upstream_prever} NTS
# Don't install tests
sed -e 's/role="test"/role="src"/' \
%{?_licensedir:-e '/LICENSE/s/role="doc"/role="src"/' } \
-i package.xml
-cd NTS
+cd %{sources}
# Sanity check, really often broken
extver=$(sed -n '/#define PHP_RDKAFKA_VERSION/{s/.* "//;s/".*$//;p}' php_rdkafka.h)
if test "x${extver}" != "x%{upstream_version}%{?upstream_prever}"; then
@@ -102,9 +105,10 @@ if test "x${extver}" != "x%{upstream_version}%{?upstream_prever}"; then
fi
cd ..
+mkdir NTS
%if %{with_zts}
# Duplicate source tree for NTS / ZTS build
-cp -pr NTS ZTS
+mkdir ZTS
%endif
# Create configuration file
@@ -117,19 +121,37 @@ EOF
%build
%{?dtsenable}
-cd NTS
-%{_bindir}/phpize
+%if %{with move_to_opt}
+# not yet used
+export PKG_CONFIG_PATH=/opt/%{?vendeur:%{vendeur}/}librdkafka/%{_lib}/pkgconfig
+%endif
+
+cd %{sources}
+%{__phpize}
+
+cd ../NTS
%configure \
- --with-php-config=%{_bindir}/php-config \
- --with-rdkafka
+ --with-php-config=%{__phpconfig} \
+ --with-libdir=%{_lib} \
+%if %{with move_to_opt}
+ --with-rdkafka=/opt/%{?vendeur:%{vendeur}/}librdkafka
+%else
+ --with-rdkafka
+%endif
+
make %{?_smp_mflags}
%if %{with_zts}
cd ../ZTS
-%{_bindir}/zts-phpize
%configure \
- --with-php-config=%{_bindir}/zts-php-config \
- --with-rdkafka
+ --with-php-config=%{__ztsphpconfig} \
+ --with-libdir=%{_lib} \
+%if %{with move_to_opt}
+ --with-rdkafka=/opt/%{?vendeur:%{vendeur}/}librdkafka
+%else
+ --with-rdkafka
+%endif
+
make %{?_smp_mflags}
%endif
@@ -153,7 +175,7 @@ install -D -m 644 %{ini_name} %{buildroot}%{php_ztsinidir}/%{ini_name}
# Documentation
for i in $(grep 'role="doc"' package.xml | sed -e 's/^.*name="//;s/".*$//')
-do install -Dpm 644 NTS/$i %{buildroot}%{pecl_docdir}/%{pecl_name}/$i
+do install -Dpm 644 %{sources}/$i %{buildroot}%{pecl_docdir}/%{pecl_name}/$i
done
@@ -178,14 +200,12 @@ fi
%check
-cd NTS
: Minimal load test for NTS extension
%{__php} --no-php-ini \
--define extension=%{buildroot}%{php_extdir}/%{pecl_name}.so \
--modules | grep '^%{pecl_name}$'
%if %{with_zts}
-cd ../ZTS
: Minimal load test for ZTS extension
%{__ztsphp} --no-php-ini \
--define extension=%{buildroot}%{php_ztsextdir}/%{pecl_name}.so \
@@ -193,14 +213,14 @@ cd ../ZTS
%endif
: Upstream test suite for NTS extension
-cd ../NTS
-TEST_PHP_ARGS="-n -d extension=$PWD/modules/%{pecl_name}.so" \
+cd %{sources}
+TEST_PHP_ARGS="-n -d extension=$PWD/../NTS/modules/%{pecl_name}.so" \
REPORT_EXIT_STATUS=1 \
%{__php} -n run-tests.php -P -q --show-diff
%files
-%{?_licensedir:%license NTS/LICENSE}
+%{?_licensedir:%license %{sources}/LICENSE}
%doc %{pecl_docdir}/%{pecl_name}
%{pecl_xmldir}/%{name}.xml
@@ -214,6 +234,19 @@ REPORT_EXIT_STATUS=1 \
%changelog
+* Wed Aug 30 2023 Remi Collet <remi@remirepo.net> - 6.0.3-4
+- rebuild for PHP 8.3.0RC1
+
+* Wed Jul 12 2023 Remi Collet <remi@remirepo.net> - 6.0.3-3
+- build out of sources tree
+
+* Thu Jan 19 2023 Remi Collet <remi@remirepo.net> - 6.0.3-2
+- rebuild using remi-librdkafka 2.0.1
+
+* Mon Jul 4 2022 Remi Collet <remi@remirepo.net> - 6.0.3-1
+- update to 6.0.3 (no change)
+- rebuild with librdkafka 1.9.0
+
* Mon Jun 13 2022 Remi Collet <remi@remirepo.net> - 6.0.2-1
- update to 6.0.2