summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--PHPINFO6
-rw-r--r--REFLECTION154
2 files changed, 114 insertions, 46 deletions
diff --git a/PHPINFO b/PHPINFO
index 3ab7a64..a732c3e 100644
--- a/PHPINFO
+++ b/PHPINFO
@@ -3,6 +3,6 @@ simple_kafka_client
kafka support => enabled
version => 0.1.4
-build date => Aug 4 2021 00:00:00
-librdkafka version (runtime) => 1.7.0
-librdkafka version (build) => 1.7.0.255
+build date => Sep 1 2021 00:00:00
+librdkafka version (runtime) => 1.9.0
+librdkafka version (build) => 1.9.0.255
diff --git a/REFLECTION b/REFLECTION
index d0d7f2c..d20ca67 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,4 +1,4 @@
-Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
+Extension [ <persistent> extension #118 simple_kafka_client version 0.1.4 ] {
- Constants [177] {
Constant [ int RD_KAFKA_OFFSET_BEGINNING ] { -2 }
@@ -9,8 +9,8 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.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 ] { 17236223 }
- Constant [ int RD_KAFKA_BUILD_VERSION ] { 17236223 }
+ Constant [ int RD_KAFKA_VERSION ] { 17367295 }
+ Constant [ int RD_KAFKA_BUILD_VERSION ] { 17367295 }
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 }
@@ -284,7 +284,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
Parameter #0 [ <required> string $token ]
Parameter #1 [ <required> int $lifetimeMs ]
Parameter #2 [ <required> string $principalName ]
- Parameter #3 [ <optional> $extensions ]
+ Parameter #3 [ <optional> ?array $extensions = null ]
}
- Return [ void ]
}
@@ -428,7 +428,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
Parameter #0 [ <required> string $token ]
Parameter #1 [ <required> int $lifetimeMs ]
Parameter #2 [ <required> string $principalName ]
- Parameter #3 [ <optional> $extensions ]
+ Parameter #3 [ <optional> ?array $extensions = null ]
}
- Return [ void ]
}
@@ -460,7 +460,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
Method [ <internal:simple_kafka_client> public method assign ] {
- Parameters [1] {
- Parameter #0 [ <optional> $topics ]
+ Parameter #0 [ <optional> ?array $topics = null ]
}
- Return [ void ]
}
@@ -602,7 +602,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
Parameter #0 [ <required> string $token ]
Parameter #1 [ <required> int $lifetimeMs ]
Parameter #2 [ <required> string $principalName ]
- Parameter #3 [ <optional> $extensions ]
+ Parameter #3 [ <optional> ?array $extensions = null ]
}
- Return [ void ]
}
@@ -704,7 +704,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
}
}
- Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Exception extends Exception implements Throwable ] {
+ Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Exception extends Exception implements Throwable, Stringable ] {
- Constants [0] {
}
@@ -716,52 +716,86 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
}
- Properties [4] {
- Property [ <default> protected $message ]
- Property [ <default> protected $code ]
- Property [ <default> protected $file ]
- Property [ <default> protected $line ]
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected $file = NULL ]
+ Property [ protected $line = NULL ]
}
- Methods [10] {
Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
- Parameters [3] {
- Parameter #0 [ <optional> $message ]
- Parameter #1 [ <optional> $code ]
- Parameter #2 [ <optional> $previous ]
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+
+ - Parameters [0] {
+ }
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+
+ - Parameters [0] {
+ }
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+
+ - Parameters [0] {
+ }
+ - Return [ int ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+
+ - Parameters [0] {
+ }
+ - Return [ array ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?Throwable ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
}
}
- Class [ <internal:simple_kafka_client> class SimpleKafkaClient\KafkaErrorException extends SimpleKafkaClient\Exception implements Throwable ] {
+ Class [ <internal:simple_kafka_client> class SimpleKafkaClient\KafkaErrorException extends SimpleKafkaClient\Exception implements Stringable, Throwable ] {
- Constants [0] {
}
@@ -773,14 +807,14 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
}
- 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 ]
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected $file = NULL ]
+ Property [ protected $line = NULL ]
+ Property [ private $error_string = NULL ]
+ Property [ private $isFatal = false ]
+ Property [ private $isRetriable = false ]
+ Property [ private $transactionRequiresAbort = false ]
}
- Methods [14] {
@@ -825,30 +859,64 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
}
Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+
+ - Parameters [0] {
+ }
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+
+ - Parameters [0] {
+ }
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+
+ - Parameters [0] {
+ }
+ - Return [ int ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+
+ - Parameters [0] {
+ }
+ - Return [ array ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?Throwable ]
}
Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+
+ - Parameters [0] {
+ }
+ - Return [ string ]
}
}
}
@@ -865,15 +933,15 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
}
- Properties [9] {
- Property [ <default> public $err ]
- Property [ <default> public $topic_name ]
- Property [ <default> public $timestamp ]
- Property [ <default> public $partition ]
- Property [ <default> public $payload ]
- Property [ <default> public $len ]
- Property [ <default> public $key ]
- Property [ <default> public $offset ]
- Property [ <default> public $headers ]
+ Property [ public $err = NULL ]
+ Property [ public $topic_name = NULL ]
+ Property [ public $timestamp = NULL ]
+ Property [ public $partition = NULL ]
+ Property [ public $payload = NULL ]
+ Property [ public $len = NULL ]
+ Property [ public $key = NULL ]
+ Property [ public $offset = NULL ]
+ Property [ public $headers = NULL ]
}
- Methods [1] {
@@ -1136,7 +1204,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
- Parameters [3] {
Parameter #0 [ <required> string $topicName ]
Parameter #1 [ <required> int $partition ]
- Parameter #2 [ <optional> $offset ]
+ Parameter #2 [ <optional> int $offset = 0 ]
}
}
@@ -1144,7 +1212,7 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
- Parameters [0] {
}
- - Return [ string or NULL ]
+ - Return [ ?string ]
}
Method [ <internal:simple_kafka_client> public method setTopicName ] {
@@ -1267,8 +1335,8 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
- Parameters [4] {
Parameter #0 [ <required> int $partition ]
Parameter #1 [ <required> int $msgFlags ]
- Parameter #2 [ <optional> $payload ]
- Parameter #3 [ <optional> $key ]
+ Parameter #2 [ <optional> ?string $payload = null ]
+ Parameter #3 [ <optional> ?string $key = null ]
}
- Return [ void ]
}
@@ -1278,10 +1346,10 @@ Extension [ <persistent> extension #122 simple_kafka_client version 0.1.4 ] {
- Parameters [6] {
Parameter #0 [ <required> int $partition ]
Parameter #1 [ <required> int $msgFlags ]
- Parameter #2 [ <optional> $payload ]
- Parameter #3 [ <optional> $key ]
- Parameter #4 [ <optional> $headers ]
- Parameter #5 [ <optional> $timestampMs ]
+ Parameter #2 [ <optional> ?string $payload = null ]
+ Parameter #3 [ <optional> ?string $key = null ]
+ Parameter #4 [ <optional> ?array $headers = null ]
+ Parameter #5 [ <optional> ?int $timestampMs = null ]
}
- Return [ void ]
}
generated by cgit (git 2.34.1) at 2024-11-22 03:30:52 +0000