summaryrefslogtreecommitdiffstats
path: root/REFLECTION
diff options
context:
space:
mode:
Diffstat (limited to 'REFLECTION')
-rw-r--r--REFLECTION133
1 files changed, 127 insertions, 6 deletions
diff --git a/REFLECTION b/REFLECTION
index 1aa657f..15ec1e5 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,6 +1,6 @@
-Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
+Extension [ <persistent> extension #97 rdkafka version 4.1.0 ] {
- - Constants [166] {
+ - Constants [172] {
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 #97 rdkafka version 4.0.4 ] {
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 ] { 17105151 }
- Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105151 }
+ Constant [ int RD_KAFKA_VERSION ] { 17105663 }
+ Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105663 }
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 }
@@ -156,6 +156,12 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
Constant [ int RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE ] { 80 }
Constant [ int RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED ] { 81 }
Constant [ int RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID ] { 82 }
+ Constant [ int RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE ] { 83 }
+ Constant [ int RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED ] { 84 }
+ Constant [ int RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS ] { 85 }
+ Constant [ int RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC ] { 86 }
+ Constant [ int RD_KAFKA_RESP_ERR_INVALID_RECORD ] { 87 }
+ Constant [ int RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT ] { 88 }
Constant [ int RD_KAFKA_CONF_UNKNOWN ] { -2 }
Constant [ int RD_KAFKA_CONF_INVALID ] { -1 }
Constant [ int RD_KAFKA_CONF_OK ] { 0 }
@@ -205,7 +211,7 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
}
}
- - Classes [19] {
+ - Classes [20] {
Class [ <internal:rdkafka> abstract class RdKafka ] {
- Constants [0] {
@@ -467,7 +473,7 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
- Properties [0] {
}
- - Methods [14] {
+ - Methods [18] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -475,6 +481,33 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
}
}
+ Method [ <internal:rdkafka> public method initTransactions ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method beginTransaction ] {
+
+ - Parameters [0] {
+ }
+ }
+
+ Method [ <internal:rdkafka> public method commitTransaction ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method abortTransaction ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> $timeout_ms ]
+ }
+ }
+
Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {
- Parameters [1] {
@@ -770,6 +803,94 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] {
}
}
+ Class [ <internal:rdkafka> class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable ] {
+
+ - Constants [0] {
+ }
+
+ - Static properties [0] {
+ }
+
+ - Static methods [0] {
+ }
+
+ - Properties [8] {
+ Property [ <default> protected $message ]
+ Property [ <default> protected $code ]
+ Property [ <default> protected $file ]
+ Property [ <default> protected $line ]
+ Property [ <default> private $error_string ]
+ Property [ <default> private $isFatal ]
+ Property [ <default> private $isRetriable ]
+ Property [ <default> private $transactionRequiresAbort ]
+ }
+
+ - Methods [14] {
+ Method [ <internal:rdkafka, overwrites Exception, ctor> public method __construct ] {
+
+ - Parameters [6] {
+ Parameter #0 [ <required> $message ]
+ Parameter #1 [ <required> $code ]
+ Parameter #2 [ <required> $error_string ]
+ Parameter #3 [ <required> $isFatal ]
+ Parameter #4 [ <required> $isRetriable ]
+ Parameter #5 [ <required> $transactionRequiresAbort ]
+ }
+ }
+
+ Method [ <internal:rdkafka> public method getErrorString ] {
+
+ - Parameters [0] {
+ }
+ }
+
+ Method [ <internal:rdkafka> public method isFatal ] {
+
+ - Parameters [0] {
+ }
+ }
+
+ Method [ <internal:rdkafka> public method isRetriable ] {
+
+ - Parameters [0] {
+ }
+ }
+
+ Method [ <internal:rdkafka> public method transactionRequiresAbort ] {
+
+ - Parameters [0] {
+ }
+ }
+
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ }
+
+ Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+ }
+ }
+ }
+
Class [ <internal:rdkafka> class RdKafka\KafkaConsumer ] {
- Constants [0] {