summaryrefslogtreecommitdiffstats
path: root/REFLECTION
diff options
context:
space:
mode:
Diffstat (limited to 'REFLECTION')
-rw-r--r--REFLECTION87
1 files changed, 78 insertions, 9 deletions
diff --git a/REFLECTION b/REFLECTION
index 36e94f1..016d951 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,6 +1,6 @@
-Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
+Extension [ <persistent> extension #128 rdkafka version 5.0.1 ] {
- - Constants [183] {
+ - Constants [184] {
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 #99 rdkafka version 5.0.0 ] {
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 ] { 17170687 }
- Constant [ int RD_KAFKA_BUILD_VERSION ] { 17170687 }
+ Constant [ int RD_KAFKA_VERSION ] { 17302271 }
+ Constant [ int RD_KAFKA_BUILD_VERSION ] { 17302271 }
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 }
@@ -73,6 +73,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Constant [ int RD_KAFKA_RESP_ERR__APPLICATION ] { -143 }
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__END ] { -100 }
Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN ] { -1 }
Constant [ int RD_KAFKA_RESP_ERR_NO_ERROR ] { 0 }
@@ -192,6 +193,12 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
- Parameters [0] {
}
}
+ Function [ <internal:rdkafka> function rd_kafka_err2name ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $err ]
+ }
+ }
Function [ <internal:rdkafka> function rd_kafka_err2str ] {
- Parameters [1] {
@@ -239,7 +246,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Property [ <default> private $dr_cb ]
}
- - Methods [13] {
+ - Methods [15] {
Method [ <internal:rdkafka> public method addBrokers ] {
- Parameters [1] {
@@ -338,6 +345,20 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Parameter #1 [ <required> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka> public method pausePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method resumePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
}
}
@@ -355,7 +376,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
- Properties [0] {
}
- - Methods [15] {
+ - Methods [17] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -467,6 +488,20 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Parameter #1 [ <required> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
}
}
@@ -484,7 +519,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
- Properties [0] {
}
- - Methods [18] {
+ - Methods [20] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -617,6 +652,20 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Parameter #1 [ <required> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
}
}
@@ -919,7 +968,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Property [ <default> private $dr_msg_cb ]
}
- - Methods [16] {
+ - Methods [18] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -1036,6 +1085,20 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Parameter #1 [ <required> $timeout_ms ]
}
}
+
+ Method [ <internal:rdkafka> public method pausePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method resumePartitions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $topic_partitions ]
+ }
+ }
}
}
@@ -1297,7 +1360,7 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
- Properties [0] {
}
- - Methods [7] {
+ - Methods [8] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [3] {
@@ -1345,6 +1408,12 @@ Extension [ <persistent> extension #99 rdkafka version 5.0.0 ] {
Parameter #0 [ <required> $offset ]
}
}
+
+ Method [ <internal:rdkafka> public method getErr ] {
+
+ - Parameters [0] {
+ }
+ }
}
}