diff options
Diffstat (limited to 'REFLECTION')
| -rw-r--r-- | REFLECTION | 87 |
1 files changed, 78 insertions, 9 deletions
@@ -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] { + } + } } } |