summaryrefslogtreecommitdiffstats
path: root/REFLECTION
diff options
context:
space:
mode:
Diffstat (limited to 'REFLECTION')
-rw-r--r--REFLECTION188
1 files changed, 150 insertions, 38 deletions
diff --git a/REFLECTION b/REFLECTION
index 7c6f71c..7ec44e4 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,14 +1,18 @@
-Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
+Extension [ <persistent> extension #136 rdkafka version 4.0.0 ] {
- - Constants [154] {
+ - Constants [161] {
Constant [ integer RD_KAFKA_CONSUMER ] { 1 }
Constant [ integer RD_KAFKA_OFFSET_BEGINNING ] { -2 }
Constant [ integer RD_KAFKA_OFFSET_END ] { -1 }
Constant [ integer RD_KAFKA_OFFSET_STORED ] { -1000 }
Constant [ integer RD_KAFKA_PARTITION_UA ] { -1 }
Constant [ integer RD_KAFKA_PRODUCER ] { 0 }
- Constant [ integer RD_KAFKA_VERSION ] { 16843007 }
- Constant [ integer RD_KAFKA_BUILD_VERSION ] { 16843007 }
+ Constant [ integer RD_KAFKA_MSG_F_BLOCK ] { 4 }
+ Constant [ integer RD_KAFKA_PURGE_F_QUEUE ] { 1 }
+ Constant [ integer RD_KAFKA_PURGE_F_INFLIGHT ] { 2 }
+ Constant [ integer RD_KAFKA_PURGE_F_NON_BLOCKING ] { 4 }
+ Constant [ integer RD_KAFKA_VERSION ] { 16908543 }
+ Constant [ integer RD_KAFKA_BUILD_VERSION ] { 16908543 }
Constant [ integer RD_KAFKA_RESP_ERR__BEGIN ] { -200 }
Constant [ integer RD_KAFKA_RESP_ERR__BAD_MSG ] { -199 }
Constant [ integer RD_KAFKA_RESP_ERR__BAD_COMPRESSION ] { -198 }
@@ -152,6 +156,9 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Constant [ integer RD_KAFKA_CONF_OK ] { 0 }
Constant [ integer RD_KAFKA_MSG_PARTITIONER_RANDOM ] { 2 }
Constant [ integer RD_KAFKA_MSG_PARTITIONER_CONSISTENT ] { 3 }
+ Constant [ integer RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM ] { 4 }
+ Constant [ integer RD_KAFKA_MSG_PARTITIONER_MURMUR2 ] { 5 }
+ Constant [ integer RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM ] { 6 }
Constant [ integer RD_KAFKA_LOG_PRINT ] { 100 }
Constant [ integer RD_KAFKA_LOG_SYSLOG ] { 101 }
Constant [ integer RD_KAFKA_LOG_SYSLOG_PRINT ] { 102 }
@@ -169,13 +176,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #0 [ <required> $err ]
}
}
- Function [ <internal:rdkafka> function rd_kafka_errno2err ] {
+ Function [ <internal, deprecated:rdkafka> function rd_kafka_errno2err ] {
- Parameters [1] {
Parameter #0 [ <required> $errnox ]
}
}
- Function [ <internal:rdkafka> function rd_kafka_errno ] {
+ Function [ <internal, deprecated:rdkafka> function rd_kafka_errno ] {
- Parameters [0] {
}
@@ -210,7 +217,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Property [ <default> private $dr_cb ]
}
- - Methods [11] {
+ - Methods [13] {
Method [ <internal:rdkafka> public method addBrokers ] {
- Parameters [1] {
@@ -242,19 +249,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka> public method setLogLevel ] {
+ Method [ <internal, deprecated:rdkafka> public method setLogLevel ] {
- Parameters [1] {
Parameter #0 [ <required> $level ]
}
}
- Method [ <internal:rdkafka> public method newQueue ] {
-
- - Parameters [0] {
- }
- }
-
Method [ <internal:rdkafka> public method newTopic ] {
- Parameters [2] {
@@ -276,7 +277,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka> public method setLogger ] {
+ Method [ <internal:rdkafka> public method flush ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method purge ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $purge_flags ]
+ }
+ }
+
+ Method [ <internal, deprecated:rdkafka> public method setLogger ] {
- Parameters [1] {
Parameter #0 [ <required> $logger ]
@@ -293,6 +308,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #4 [ <optional> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+ - Parameters [2] {
+ Parameter #0 [ <required> $topic_partitions ]
+ Parameter #1 [ <required> $timeout_ms ]
+ }
+ }
}
}
@@ -310,7 +333,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
- Properties [0] {
}
- - Methods [12] {
+ - Methods [15] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -318,6 +341,12 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
+ Method [ <internal:rdkafka> public method newQueue ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {
- Parameters [1] {
@@ -349,19 +378,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method setLogLevel ] {
+ Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
- Parameters [1] {
Parameter #0 [ <required> $level ]
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method newQueue ] {
-
- - Parameters [0] {
- }
- }
-
Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
- Parameters [2] {
@@ -383,7 +406,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method setLogger ] {
+ Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $purge_flags ]
+ }
+ }
+
+ Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
- Parameters [1] {
Parameter #0 [ <required> $logger ]
@@ -400,6 +437,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #4 [ <optional> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+ - Parameters [2] {
+ Parameter #0 [ <required> $topic_partitions ]
+ Parameter #1 [ <required> $timeout_ms ]
+ }
+ }
}
}
@@ -417,7 +462,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
- Properties [0] {
}
- - Methods [12] {
+ - Methods [14] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -456,19 +501,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method setLogLevel ] {
+ Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
- Parameters [1] {
Parameter #0 [ <required> $level ]
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method newQueue ] {
-
- - Parameters [0] {
- }
- }
-
Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
- Parameters [2] {
@@ -490,7 +529,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka, inherits RdKafka> public method setLogger ] {
+ Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $purge_flags ]
+ }
+ }
+
+ Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
- Parameters [1] {
Parameter #0 [ <required> $logger ]
@@ -507,6 +560,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #4 [ <optional> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+ - Parameters [2] {
+ Parameter #0 [ <required> $topic_partitions ]
+ Parameter #1 [ <required> $timeout_ms ]
+ }
+ }
}
}
@@ -581,7 +642,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
- Properties [0] {
}
- - Methods [10] {
+ - Methods [11] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [0] {
@@ -602,7 +663,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
- Method [ <internal:rdkafka> public method setDefaultTopicConf ] {
+ Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] {
- Parameters [1] {
Parameter #0 [ <required> $topic_conf ]
@@ -650,6 +711,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #0 [ <required> $callback ]
}
}
+
+ Method [ <internal:rdkafka> public method setLogCb ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $callback ]
+ }
+ }
}
}
@@ -714,7 +782,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Property [ <default> private $dr_msg_cb ]
}
- - Methods [12] {
+ - Methods [16] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -742,6 +810,12 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
+ Method [ <internal:rdkafka> public method close ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka> public method commitAsync ] {
- Parameters [1] {
@@ -799,6 +873,32 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
Parameter #1 [ <required> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka> public method getOffsetPositions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {
+
+ - Parameters [5] {
+ Parameter #0 [ <required> $topic ]
+ Parameter #1 [ <optional> $partition ]
+ Parameter #2 [ <optional> &$low ]
+ Parameter #3 [ <optional> &$high ]
+ Parameter #4 [ <optional> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+ - Parameters [2] {
+ Parameter #0 [ <required> $topic_partitions ]
+ Parameter #1 [ <required> $timeout_ms ]
+ }
+ }
}
}
@@ -1062,7 +1162,10 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
- Methods [7] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- - Parameters [0] {
+ - Parameters [3] {
+ Parameter #0 [ <required> $topic ]
+ Parameter #1 [ <required> $partition ]
+ Parameter #2 [ <optional> $offset ]
}
}
@@ -1174,7 +1277,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
- Properties [0] {
}
- - Methods [7] {
+ - Methods [8] {
Method [ <internal:rdkafka, ctor> private method __construct ] {
- Parameters [0] {
@@ -1213,6 +1316,15 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
}
}
+ Method [ <internal:rdkafka> public method consumeBatch ] {
+
+ - Parameters [3] {
+ Parameter #0 [ <required> $partition ]
+ Parameter #1 [ <required> $timeout_ms ]
+ Parameter #2 [ <required> $batch_size ]
+ }
+ }
+
Method [ <internal:rdkafka> public method offsetStore ] {
- Parameters [2] {
generated by cgit (git 2.34.1) at 2024-11-22 04:15:36 +0000