summaryrefslogtreecommitdiffstats
path: root/REFLECTION
diff options
context:
space:
mode:
Diffstat (limited to 'REFLECTION')
-rw-r--r--REFLECTION179
1 files changed, 165 insertions, 14 deletions
diff --git a/REFLECTION b/REFLECTION
index a7d9798..85f829d 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,6 +1,6 @@
-Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
+Extension [ <persistent> extension #94 rdkafka version 6.0.4 ] {
- - Constants [185] {
+ - Constants [193] {
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 #124 rdkafka version 6.0.3 ] {
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 ] { 33685759 }
- Constant [ int RD_KAFKA_BUILD_VERSION ] { 33554687 }
+ Constant [ int RD_KAFKA_VERSION ] { 33947903 }
+ Constant [ int RD_KAFKA_BUILD_VERSION ] { 33947903 }
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 }
@@ -75,6 +75,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
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__INVALID_DIFFERENT_RECORD ] { -138 }
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 }
@@ -175,6 +176,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
Constant [ int RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION ] { 95 }
Constant [ int RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED ] { 96 }
Constant [ int RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE ] { 97 }
+ Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID ] { 100 }
+ Constant [ int RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH ] { 110 }
+ Constant [ int RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID ] { 111 }
+ Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR ] { 112 }
+ Constant [ int RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH ] { 113 }
+ Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID ] { 117 }
+ Constant [ int RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE ] { 118 }
Constant [ int RD_KAFKA_CONF_UNKNOWN ] { -2 }
Constant [ int RD_KAFKA_CONF_INVALID ] { -1 }
Constant [ int RD_KAFKA_CONF_OK ] { 0 }
@@ -254,7 +262,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
Property [ private ?callable $dr_cb ]
}
- - Methods [16] {
+ - Methods [19] {
Method [ <internal:rdkafka, ctor> private method __construct ] {
- Parameters [0] {
@@ -279,6 +287,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Tentative return [ RdKafka\Metadata ]
}
+ Method [ <internal:rdkafka> public method getControllerId ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> int $timeout_ms ]
+ }
+ - Tentative return [ int ]
+ }
+
Method [ <internal:rdkafka> public method getOutQLen ] {
- Parameters [0] {
@@ -388,6 +404,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
}
- Tentative return [ array ]
}
+
+ Method [ <internal:rdkafka> public method oauthbearerSetToken ] {
+
+ - Parameters [4] {
+ Parameter #0 [ <required> string $token_value ]
+ Parameter #1 [ <required> int $lifetime_ms ]
+ Parameter #2 [ <required> string $principal_name ]
+ Parameter #3 [ <optional> array $extensions = [] ]
+ }
+ - Tentative return [ void ]
+ }
+
+ Method [ <internal:rdkafka> public method oauthbearerSetTokenFailure ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> string $error ]
+ }
+ - Tentative return [ void ]
+ }
}
}
@@ -405,7 +440,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [17] {
+ - Methods [20] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -438,6 +473,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Tentative return [ RdKafka\Metadata ]
}
+ Method [ <internal:rdkafka, inherits RdKafka> public method getControllerId ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> int $timeout_ms ]
+ }
+ - Tentative return [ int ]
+ }
+
Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {
- Parameters [0] {
@@ -547,6 +590,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
}
- Tentative return [ array ]
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetToken ] {
+
+ - Parameters [4] {
+ Parameter #0 [ <required> string $token_value ]
+ Parameter #1 [ <required> int $lifetime_ms ]
+ Parameter #2 [ <required> string $principal_name ]
+ Parameter #3 [ <optional> array $extensions = [] ]
+ }
+ - Tentative return [ void ]
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetTokenFailure ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> string $error ]
+ }
+ - Tentative return [ void ]
+ }
}
}
@@ -564,7 +626,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [20] {
+ - Methods [23] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -621,6 +683,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Tentative return [ RdKafka\Metadata ]
}
+ Method [ <internal:rdkafka, inherits RdKafka> public method getControllerId ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> int $timeout_ms ]
+ }
+ - Tentative return [ int ]
+ }
+
Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {
- Parameters [0] {
@@ -730,6 +800,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
}
- Tentative return [ array ]
}
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetToken ] {
+
+ - Parameters [4] {
+ Parameter #0 [ <required> string $token_value ]
+ Parameter #1 [ <required> int $lifetime_ms ]
+ Parameter #2 [ <required> string $principal_name ]
+ Parameter #3 [ <optional> array $extensions = [] ]
+ }
+ - Tentative return [ void ]
+ }
+
+ Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetTokenFailure ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> string $error ]
+ }
+ - Tentative return [ void ]
+ }
}
}
@@ -839,7 +928,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [11] {
+ - Methods [12] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [0] {
@@ -925,6 +1014,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
}
- Tentative return [ void ]
}
+
+ Method [ <internal:rdkafka> public method setOauthbearerTokenRefreshCb ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> callable $callback ]
+ }
+ - Tentative return [ void ]
+ }
}
}
@@ -1119,7 +1216,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
Property [ private ?callable $dr_msg_cb ]
}
- - Methods [18] {
+ - Methods [21] {
Method [ <internal:rdkafka, ctor> public method __construct ] {
- Parameters [1] {
@@ -1135,6 +1232,22 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Tentative return [ void ]
}
+ Method [ <internal:rdkafka> public method incrementalAssign ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> array $topic_partitions ]
+ }
+ - Tentative return [ void ]
+ }
+
+ Method [ <internal:rdkafka> public method incrementalUnassign ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> array $topic_partitions ]
+ }
+ - Tentative return [ void ]
+ }
+
Method [ <internal:rdkafka> public method getAssignment ] {
- Parameters [0] {
@@ -1205,6 +1318,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Tentative return [ RdKafka\Metadata ]
}
+ Method [ <internal:rdkafka> public method getControllerId ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> int $timeout_ms ]
+ }
+ - Tentative return [ int ]
+ }
+
Method [ <internal:rdkafka> public method newTopic ] {
- Parameters [2] {
@@ -1318,7 +1439,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [4] {
+ - Methods [5] {
+ Method [ <internal:rdkafka, ctor> private method __construct ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka> public method getOrigBrokerId ] {
- Parameters [0] {
@@ -1363,7 +1490,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [3] {
+ - Methods [4] {
+ Method [ <internal:rdkafka, ctor> private method __construct ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka> public method getTopic ] {
- Parameters [0] {
@@ -1401,7 +1534,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [3] {
+ - Methods [4] {
+ Method [ <internal:rdkafka, ctor> private method __construct ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka> public method getId ] {
- Parameters [0] {
@@ -1439,7 +1578,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [5] {
+ - Methods [6] {
+ Method [ <internal:rdkafka, ctor> private method __construct ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka> public method getId ] {
- Parameters [0] {
@@ -1491,7 +1636,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] {
- Properties [0] {
}
- - Methods [6] {
+ - Methods [7] {
+ Method [ <internal:rdkafka, ctor> private method __construct ] {
+
+ - Parameters [0] {
+ }
+ }
+
Method [ <internal:rdkafka, prototype Countable> public method count ] {
- Parameters [0] {