Extension [ extension #124 rdkafka version 6.0.3 ] { - Constants [185] { Constant [ int RD_KAFKA_CONSUMER ] { 1 } Constant [ int RD_KAFKA_OFFSET_BEGINNING ] { -2 } Constant [ int RD_KAFKA_OFFSET_END ] { -1 } Constant [ int RD_KAFKA_OFFSET_STORED ] { -1000 } Constant [ int RD_KAFKA_PARTITION_UA ] { -1 } Constant [ int RD_KAFKA_PRODUCER ] { 0 } Constant [ int RD_KAFKA_MSG_F_BLOCK ] { 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 ] { 33685759 } Constant [ int RD_KAFKA_BUILD_VERSION ] { 33554687 } 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 } Constant [ int RD_KAFKA_RESP_ERR__DESTROY ] { -197 } Constant [ int RD_KAFKA_RESP_ERR__FAIL ] { -196 } Constant [ int RD_KAFKA_RESP_ERR__TRANSPORT ] { -195 } Constant [ int RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE ] { -194 } Constant [ int RD_KAFKA_RESP_ERR__RESOLVE ] { -193 } Constant [ int RD_KAFKA_RESP_ERR__MSG_TIMED_OUT ] { -192 } Constant [ int RD_KAFKA_RESP_ERR__PARTITION_EOF ] { -191 } Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION ] { -190 } Constant [ int RD_KAFKA_RESP_ERR__FS ] { -189 } Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC ] { -188 } Constant [ int RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN ] { -187 } Constant [ int RD_KAFKA_RESP_ERR__INVALID_ARG ] { -186 } Constant [ int RD_KAFKA_RESP_ERR__TIMED_OUT ] { -185 } Constant [ int RD_KAFKA_RESP_ERR__QUEUE_FULL ] { -184 } Constant [ int RD_KAFKA_RESP_ERR__ISR_INSUFF ] { -183 } Constant [ int RD_KAFKA_RESP_ERR__NODE_UPDATE ] { -182 } Constant [ int RD_KAFKA_RESP_ERR__SSL ] { -181 } Constant [ int RD_KAFKA_RESP_ERR__WAIT_COORD ] { -180 } Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_GROUP ] { -179 } Constant [ int RD_KAFKA_RESP_ERR__IN_PROGRESS ] { -178 } Constant [ int RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS ] { -177 } Constant [ int RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION ] { -176 } Constant [ int RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS ] { -175 } Constant [ int RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS ] { -174 } Constant [ int RD_KAFKA_RESP_ERR__CONFLICT ] { -173 } Constant [ int RD_KAFKA_RESP_ERR__STATE ] { -172 } Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL ] { -171 } Constant [ int RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED ] { -170 } Constant [ int RD_KAFKA_RESP_ERR__AUTHENTICATION ] { -169 } Constant [ int RD_KAFKA_RESP_ERR__NO_OFFSET ] { -168 } Constant [ int RD_KAFKA_RESP_ERR__OUTDATED ] { -167 } Constant [ int RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE ] { -166 } Constant [ int RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE ] { -165 } Constant [ int RD_KAFKA_RESP_ERR__WAIT_CACHE ] { -164 } Constant [ int RD_KAFKA_RESP_ERR__INTR ] { -163 } Constant [ int RD_KAFKA_RESP_ERR__KEY_SERIALIZATION ] { -162 } Constant [ int RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION ] { -161 } Constant [ int RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION ] { -160 } Constant [ int RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION ] { -159 } Constant [ int RD_KAFKA_RESP_ERR__PARTIAL ] { -158 } Constant [ int RD_KAFKA_RESP_ERR__READ_ONLY ] { -157 } Constant [ int RD_KAFKA_RESP_ERR__NOENT ] { -156 } Constant [ int RD_KAFKA_RESP_ERR__UNDERFLOW ] { -155 } Constant [ int RD_KAFKA_RESP_ERR__INVALID_TYPE ] { -154 } Constant [ int RD_KAFKA_RESP_ERR__RETRY ] { -153 } Constant [ int RD_KAFKA_RESP_ERR__PURGE_QUEUE ] { -152 } Constant [ int RD_KAFKA_RESP_ERR__PURGE_INFLIGHT ] { -151 } Constant [ int RD_KAFKA_RESP_ERR__FATAL ] { -150 } Constant [ int RD_KAFKA_RESP_ERR__INCONSISTENT ] { -149 } Constant [ int RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE ] { -148 } Constant [ int RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED ] { -147 } Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_BROKER ] { -146 } Constant [ int RD_KAFKA_RESP_ERR__NOT_CONFIGURED ] { -145 } Constant [ int RD_KAFKA_RESP_ERR__FENCED ] { -144 } 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__LOG_TRUNCATION ] { -139 } 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 } Constant [ int RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE ] { 1 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_MSG ] { 2 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART ] { 3 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE ] { 4 } Constant [ int RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE ] { 5 } Constant [ int RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION ] { 6 } Constant [ int RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT ] { 7 } Constant [ int RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE ] { 8 } Constant [ int RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE ] { 9 } Constant [ int RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE ] { 10 } Constant [ int RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH ] { 11 } Constant [ int RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE ] { 12 } Constant [ int RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION ] { 13 } Constant [ int RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS ] { 14 } Constant [ int RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE ] { 15 } Constant [ int RD_KAFKA_RESP_ERR_NOT_COORDINATOR ] { 16 } Constant [ int RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION ] { 17 } Constant [ int RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE ] { 18 } Constant [ int RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS ] { 19 } Constant [ int RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND ] { 20 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS ] { 21 } Constant [ int RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION ] { 22 } Constant [ int RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL ] { 23 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_GROUP_ID ] { 24 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID ] { 25 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT ] { 26 } Constant [ int RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS ] { 27 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE ] { 28 } Constant [ int RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED ] { 29 } Constant [ int RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED ] { 30 } Constant [ int RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED ] { 31 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP ] { 32 } Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM ] { 33 } Constant [ int RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE ] { 34 } Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION ] { 35 } Constant [ int RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS ] { 36 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_PARTITIONS ] { 37 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR ] { 38 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT ] { 39 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_CONFIG ] { 40 } Constant [ int RD_KAFKA_RESP_ERR_NOT_CONTROLLER ] { 41 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_REQUEST ] { 42 } Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT ] { 43 } Constant [ int RD_KAFKA_RESP_ERR_POLICY_VIOLATION ] { 44 } Constant [ int RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER ] { 45 } Constant [ int RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER ] { 46 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH ] { 47 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_TXN_STATE ] { 48 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING ] { 49 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT ] { 50 } Constant [ int RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS ] { 51 } Constant [ int RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED ] { 52 } Constant [ int RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED ] { 53 } Constant [ int RD_KAFKA_RESP_ERR_SECURITY_DISABLED ] { 54 } Constant [ int RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED ] { 55 } Constant [ int RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR ] { 56 } Constant [ int RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND ] { 57 } Constant [ int RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED ] { 58 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID ] { 59 } Constant [ int RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS ] { 60 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED ] { 61 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND ] { 62 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH ] { 63 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED ] { 64 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED ] { 65 } Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED ] { 66 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE ] { 67 } Constant [ int RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP ] { 68 } Constant [ int RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND ] { 69 } Constant [ int RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND ] { 70 } Constant [ int RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH ] { 71 } Constant [ int RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND ] { 72 } Constant [ int RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED ] { 73 } Constant [ int RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH ] { 74 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH ] { 75 } Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE ] { 76 } Constant [ int RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH ] { 77 } Constant [ int RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE ] { 78 } Constant [ int RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED ] { 79 } 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_RESP_ERR_THROTTLING_QUOTA_EXCEEDED ] { 89 } Constant [ int RD_KAFKA_RESP_ERR_PRODUCER_FENCED ] { 90 } Constant [ int RD_KAFKA_RESP_ERR_RESOURCE_NOT_FOUND ] { 91 } Constant [ int RD_KAFKA_RESP_ERR_DUPLICATE_RESOURCE ] { 92 } Constant [ int RD_KAFKA_RESP_ERR_UNACCEPTABLE_CREDENTIAL ] { 93 } Constant [ int RD_KAFKA_RESP_ERR_INCONSISTENT_VOTER_SET ] { 94 } 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_CONF_UNKNOWN ] { -2 } Constant [ int RD_KAFKA_CONF_INVALID ] { -1 } Constant [ int RD_KAFKA_CONF_OK ] { 0 } Constant [ int RD_KAFKA_MSG_PARTITIONER_RANDOM ] { 2 } Constant [ int RD_KAFKA_MSG_PARTITIONER_CONSISTENT ] { 3 } Constant [ int RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM ] { 4 } Constant [ int RD_KAFKA_MSG_PARTITIONER_MURMUR2 ] { 5 } Constant [ int RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM ] { 6 } Constant [ int RD_KAFKA_LOG_PRINT ] { 100 } Constant [ int RD_KAFKA_LOG_SYSLOG ] { 101 } Constant [ int RD_KAFKA_LOG_SYSLOG_PRINT ] { 102 } } - Functions { Function [ function rd_kafka_get_err_descs ] { - Parameters [0] { } - Return [ array ] } Function [ function rd_kafka_err2name ] { - Parameters [1] { Parameter #0 [ int $err ] } - Return [ ?string ] } Function [ function rd_kafka_err2str ] { - Parameters [1] { Parameter #0 [ int $err ] } - Return [ ?string ] } Function [ function rd_kafka_errno2err ] { - Parameters [1] { Parameter #0 [ int $errnox ] } - Return [ int ] } Function [ function rd_kafka_errno ] { - Parameters [0] { } - Return [ int ] } Function [ function rd_kafka_offset_tail ] { - Parameters [1] { Parameter #0 [ int $cnt ] } - Return [ int ] } Function [ function rd_kafka_thread_cnt ] { - Parameters [0] { } - Return [ int ] } } - Classes [20] { Class [ abstract class RdKafka ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [2] { Property [ private ?callable $error_cb ] Property [ private ?callable $dr_cb ] } - Methods [16] { Method [ private method __construct ] { - Parameters [0] { } } Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } - Tentative return [ int ] } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ int $level ] } - Tentative return [ void ] } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } - Tentative return [ int ] } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ int $logger ] } - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ string $topic ] Parameter #1 [ int $partition ] Parameter #2 [ int &$low ] Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ array ] } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } } } Class [ class RdKafka\Consumer extends RdKafka ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [17] { Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ ?RdKafka\Conf $conf = null ] } } Method [ public method newQueue ] { - Parameters [0] { } - Tentative return [ RdKafka\Queue ] } Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } - Tentative return [ int ] } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ int $level ] } - Tentative return [ void ] } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } - Tentative return [ int ] } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ int $logger ] } - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ string $topic ] Parameter #1 [ int $partition ] Parameter #2 [ int &$low ] Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ array ] } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } } } Class [ class RdKafka\Producer extends RdKafka ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [20] { Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ ?RdKafka\Conf $conf = null ] } } Method [ public method initTransactions ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method beginTransaction ] { - Parameters [0] { } - Tentative return [ void ] } Method [ public method commitTransaction ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method abortTransaction ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ string $broker_list ] } - Tentative return [ int ] } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method getOutQLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ int $level ] } - Tentative return [ void ] } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } - Tentative return [ RdKafka\Topic ] } Method [ public method outqLen ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ int ] } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ int $purge_flags ] } - Tentative return [ int ] } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ int $logger ] } - Tentative return [ void ] } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ string $topic ] Parameter #1 [ int $partition ] Parameter #2 [ int &$low ] Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ array ] } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } } } Class [ class RdKafka\Exception extends Exception implements Throwable, Stringable ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [4] { Property [ protected $message = '' ] Property [ protected $code = 0 ] Property [ protected string $file = '' ] Property [ protected int $line = 0 ] } - Methods [10] { Method [ public method __construct ] { - Parameters [3] { Parameter #0 [ string $message = "" ] Parameter #1 [ int $code = 0 ] Parameter #2 [ ?Throwable $previous = null ] } } Method [ public method __wakeup ] { - Parameters [0] { } - Tentative return [ void ] } Method [ final public method getMessage ] { - Parameters [0] { } - Return [ string ] } Method [ final public method getCode ] { - Parameters [0] { } } Method [ final public method getFile ] { - Parameters [0] { } - Return [ string ] } Method [ final public method getLine ] { - Parameters [0] { } - Return [ int ] } Method [ final public method getTrace ] { - Parameters [0] { } - Return [ array ] } Method [ final public method getPrevious ] { - Parameters [0] { } - Return [ ?Throwable ] } Method [ final public method getTraceAsString ] { - Parameters [0] { } - Return [ string ] } Method [ public method __toString ] { - Parameters [0] { } - Return [ string ] } } } Class [ class RdKafka\Conf ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [11] { Method [ public method __construct ] { - Parameters [0] { } } Method [ public method dump ] { - Parameters [0] { } - Tentative return [ array ] } Method [ public method set ] { - Parameters [2] { Parameter #0 [ string $name ] Parameter #1 [ string $value ] } - Tentative return [ void ] } Method [ public method setDefaultTopicConf ] { - Parameters [1] { Parameter #0 [ RdKafka\TopicConf $topic_conf ] } - Tentative return [ void ] } Method [ public method setErrorCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setDrMsgCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setStatsCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setRebalanceCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setConsumeCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setOffsetCommitCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } Method [ public method setLogCb ] { - Parameters [1] { Parameter #0 [ callable $callback ] } - Tentative return [ void ] } } } Class [ class RdKafka\TopicConf ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [4] { Method [ public method __construct ] { - Parameters [0] { } } Method [ public method dump ] { - Parameters [0] { } - Tentative return [ array ] } Method [ public method set ] { - Parameters [2] { Parameter #0 [ string $name ] Parameter #1 [ string $value ] } - Tentative return [ void ] } Method [ public method setPartitioner ] { - Parameters [1] { Parameter #0 [ int $partitioner ] } - Tentative return [ void ] } } } Class [ class RdKafka\KafkaErrorException extends RdKafka\Exception implements Stringable, Throwable ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [8] { Property [ protected $message = '' ] Property [ protected $code = 0 ] Property [ protected string $file = '' ] Property [ protected int $line = 0 ] Property [ private string $error_string ] Property [ private bool $isFatal ] Property [ private bool $isRetriable ] Property [ private bool $transactionRequiresAbort ] } - Methods [14] { Method [ public method __construct ] { - Parameters [6] { Parameter #0 [ string $message ] Parameter #1 [ int $code ] Parameter #2 [ string $error_string ] Parameter #3 [ bool $isFatal ] Parameter #4 [ bool $isRetriable ] Parameter #5 [ bool $transactionRequiresAbort ] } } Method [ public method getErrorString ] { - Parameters [0] { } - Tentative return [ string ] } Method [ public method isFatal ] { - Parameters [0] { } - Tentative return [ bool ] } Method [ public method isRetriable ] { - Parameters [0] { } - Tentative return [ bool ] } Method [ public method transactionRequiresAbort ] { - Parameters [0] { } - Tentative return [ bool ] } Method [ public method __wakeup ] { - Parameters [0] { } - Tentative return [ void ] } Method [ final public method getMessage ] { - Parameters [0] { } - Return [ string ] } Method [ final public method getCode ] { - Parameters [0] { } } Method [ final public method getFile ] { - Parameters [0] { } - Return [ string ] } Method [ final public method getLine ] { - Parameters [0] { } - Return [ int ] } Method [ final public method getTrace ] { - Parameters [0] { } - Return [ array ] } Method [ final public method getPrevious ] { - Parameters [0] { } - Return [ ?Throwable ] } Method [ final public method getTraceAsString ] { - Parameters [0] { } - Return [ string ] } Method [ public method __toString ] { - Parameters [0] { } - Return [ string ] } } } Class [ class RdKafka\KafkaConsumer ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [3] { Property [ private ?callable $error_cb ] Property [ private ?callable $rebalance_cb ] Property [ private ?callable $dr_msg_cb ] } - Methods [18] { Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ RdKafka\Conf $conf ] } } Method [ public method assign ] { - Parameters [1] { Parameter #0 [ ?array $topic_partitions = null ] } - Tentative return [ void ] } Method [ public method getAssignment ] { - Parameters [0] { } - Tentative return [ array ] } Method [ public method commit ] { - Parameters [1] { Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } - Tentative return [ void ] } Method [ public method close ] { - Parameters [0] { } - Tentative return [ void ] } Method [ public method commitAsync ] { - Parameters [1] { Parameter #0 [ RdKafka\Message|array|null $message_or_offsets = null ] } - Tentative return [ void ] } Method [ public method consume ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ RdKafka\Message ] } Method [ public method subscribe ] { - Parameters [1] { Parameter #0 [ array $topics ] } - Tentative return [ void ] } Method [ public method getSubscription ] { - Parameters [0] { } - Tentative return [ array ] } Method [ public method unsubscribe ] { - Parameters [0] { } - Tentative return [ void ] } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ bool $all_topics ] Parameter #1 [ ?RdKafka\Topic $only_topic ] Parameter #2 [ int $timeout_ms ] } - Tentative return [ RdKafka\Metadata ] } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ string $topic_name ] Parameter #1 [ ?RdKafka\TopicConf $topic_conf = null ] } - Tentative return [ RdKafka\KafkaConsumerTopic ] } Method [ public method getCommittedOffsets ] { - Parameters [2] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ array ] } Method [ public method getOffsetPositions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ string $topic ] Parameter #1 [ int $partition ] Parameter #2 [ int &$low ] Parameter #3 [ int &$high ] Parameter #4 [ int $timeout_ms ] } - Tentative return [ void ] } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ array $topic_partitions ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ array ] } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ array $topic_partitions ] } - Tentative return [ array ] } } } Class [ class RdKafka\Message ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [10] { Property [ public int $err ] Property [ public ?string $topic_name = NULL ] Property [ public ?int $timestamp = NULL ] Property [ public int $partition ] Property [ public ?string $payload = NULL ] Property [ public ?int $len = NULL ] Property [ public ?string $key = NULL ] Property [ public int $offset ] Property [ public array $headers ] Property [ public ?string $opaque = NULL ] } - Methods [1] { Method [ public method errstr ] { - Parameters [0] { } - Tentative return [ ?string ] } } } Class [ class RdKafka\Metadata ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [4] { Method [ public method getOrigBrokerId ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getOrigBrokerName ] { - Parameters [0] { } - Tentative return [ string ] } Method [ public method getBrokers ] { - Parameters [0] { } - Tentative return [ RdKafka\Metadata\Collection ] } Method [ public method getTopics ] { - Parameters [0] { } - Tentative return [ RdKafka\Metadata\Collection ] } } } Class [ class RdKafka\Metadata\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [3] { Method [ public method getTopic ] { - Parameters [0] { } - Tentative return [ string ] } Method [ public method getErr ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getPartitions ] { - Parameters [0] { } - Tentative return [ RdKafka\Metadata\Collection ] } } } Class [ class RdKafka\Metadata\Broker ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [3] { Method [ public method getId ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getHost ] { - Parameters [0] { } - Tentative return [ string ] } Method [ public method getPort ] { - Parameters [0] { } - Tentative return [ int ] } } } Class [ class RdKafka\Metadata\Partition ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [5] { Method [ public method getId ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getErr ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getLeader ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method getReplicas ] { - Parameters [0] { } - Tentative return [ RdKafka\Metadata\Collection ] } Method [ public method getIsrs ] { - Parameters [0] { } - Tentative return [ RdKafka\Metadata\Collection ] } } } Class [ class RdKafka\Metadata\Collection implements Countable, Iterator, Traversable ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [6] { Method [ public method count ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method current ] { - Parameters [0] { } - Tentative return [ mixed ] } Method [ public method key ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method next ] { - Parameters [0] { } - Tentative return [ void ] } Method [ public method rewind ] { - Parameters [0] { } - Tentative return [ void ] } Method [ public method valid ] { - Parameters [0] { } - Tentative return [ bool ] } } } Class [ class RdKafka\TopicPartition ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [8] { Method [ public method __construct ] { - Parameters [3] { Parameter #0 [ string $topic ] Parameter #1 [ int $partition ] Parameter #2 [ int $offset = 0 ] } } Method [ public method getTopic ] { - Parameters [0] { } - Tentative return [ ?string ] } Method [ public method setTopic ] { - Parameters [1] { Parameter #0 [ string $topic_name ] } - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getPartition ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method setPartition ] { - Parameters [1] { Parameter #0 [ int $partition ] } - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getOffset ] { - Parameters [0] { } - Tentative return [ int ] } Method [ public method setOffset ] { - Parameters [1] { Parameter #0 [ int $offset ] } - Tentative return [ RdKafka\TopicPartition ] } Method [ public method getErr ] { - Parameters [0] { } - Tentative return [ ?int ] } } } Class [ class RdKafka\Queue ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [2] { Method [ private method __construct ] { - Parameters [0] { } } Method [ public method consume ] { - Parameters [1] { Parameter #0 [ int $timeout_ms ] } - Tentative return [ ?RdKafka\Message ] } } } Class [ abstract class RdKafka\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [1] { Method [ public method getName ] { - Parameters [0] { } - Tentative return [ string ] } } } Class [ class RdKafka\ConsumerTopic extends RdKafka\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [9] { Method [ private method __construct ] { - Parameters [0] { } } Method [ public method consumeQueueStart ] { - Parameters [3] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] Parameter #2 [ RdKafka\Queue $queue ] } - Tentative return [ void ] } Method [ public method consumeCallback ] { - Parameters [3] { Parameter #0 [ int $partition ] Parameter #1 [ int $timeout_ms ] Parameter #2 [ callable $callback ] } - Tentative return [ int ] } Method [ public method consumeStart ] { - Parameters [2] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } - Tentative return [ void ] } Method [ public method consumeStop ] { - Parameters [1] { Parameter #0 [ int $partition ] } - Tentative return [ void ] } Method [ public method consume ] { - Parameters [2] { Parameter #0 [ int $partition ] Parameter #1 [ int $timeout_ms ] } - Tentative return [ ?RdKafka\Message ] } Method [ public method consumeBatch ] { - Parameters [3] { Parameter #0 [ int $partition ] Parameter #1 [ int $timeout_ms ] Parameter #2 [ int $batch_size ] } - Tentative return [ array ] } Method [ public method offsetStore ] { - Parameters [2] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } - Tentative return [ string ] } } } Class [ class RdKafka\KafkaConsumerTopic extends RdKafka\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [3] { Method [ private method __construct ] { - Parameters [0] { } } Method [ public method offsetStore ] { - Parameters [2] { Parameter #0 [ int $partition ] Parameter #1 [ int $offset ] } - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } - Tentative return [ string ] } } } Class [ class RdKafka\ProducerTopic extends RdKafka\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [4] { Method [ private method __construct ] { - Parameters [0] { } } Method [ public method produce ] { - Parameters [5] { Parameter #0 [ int $partition ] Parameter #1 [ int $msgflags ] Parameter #2 [ ?string $payload = null ] Parameter #3 [ ?string $key = null ] Parameter #4 [ ?string $msg_opaque = null ] } - Tentative return [ void ] } Method [ public method producev ] { - Parameters [7] { Parameter #0 [ int $partition ] Parameter #1 [ int $msgflags ] Parameter #2 [ ?string $payload = null ] Parameter #3 [ ?string $key = null ] Parameter #4 [ ?array $headers = null ] Parameter #5 [ ?int $timestamp_ms = null ] Parameter #6 [ ?string $msg_opaque = null ] } - Tentative return [ void ] } Method [ public method getName ] { - Parameters [0] { } - Tentative return [ string ] } } } } }