Extension [ extension #128 rdkafka version 5.0.1 ] { - Constants [184] { 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 ] { 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 } 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__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] { } } Function [ function rd_kafka_err2name ] { - Parameters [1] { Parameter #0 [ $err ] } } Function [ function rd_kafka_err2str ] { - Parameters [1] { Parameter #0 [ $err ] } } Function [ function rd_kafka_errno2err ] { - Parameters [1] { Parameter #0 [ $errnox ] } } Function [ function rd_kafka_errno ] { - Parameters [0] { } } Function [ function rd_kafka_offset_tail ] { - Parameters [1] { Parameter #0 [ $cnt ] } } Function [ function rd_kafka_thread_cnt ] { - Parameters [0] { } } } - Classes [20] { Class [ abstract class RdKafka ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [2] { Property [ private $error_cb ] Property [ private $dr_cb ] } - Methods [15] { Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method getOutQLen ] { - Parameters [0] { } } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ $level ] } } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ $topic_name ] Parameter #1 [ $topic_conf ] } } Method [ public method outqLen ] { - Parameters [0] { } } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ $topic ] Parameter #1 [ $partition ] Parameter #2 [ &$low ] Parameter #3 [ &$high ] Parameter #4 [ $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ $topic_partitions ] Parameter #1 [ $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } } } 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 [ $conf ] } } Method [ public method newQueue ] { - Parameters [0] { } } Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method getOutQLen ] { - Parameters [0] { } } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ $level ] } } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ $topic_name ] Parameter #1 [ $topic_conf ] } } Method [ public method outqLen ] { - Parameters [0] { } } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ $topic ] Parameter #1 [ $partition ] Parameter #2 [ &$low ] Parameter #3 [ &$high ] Parameter #4 [ $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ $topic_partitions ] Parameter #1 [ $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } } } 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 [ $conf ] } } Method [ public method initTransactions ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method beginTransaction ] { - Parameters [0] { } } Method [ public method commitTransaction ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method abortTransaction ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method addBrokers ] { - Parameters [1] { Parameter #0 [ $broker_list ] } } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method getOutQLen ] { - Parameters [0] { } } Method [ public method metadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method setLogLevel ] { - Parameters [1] { Parameter #0 [ $level ] } } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ $topic_name ] Parameter #1 [ $topic_conf ] } } Method [ public method outqLen ] { - Parameters [0] { } } Method [ public method poll ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method flush ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method purge ] { - Parameters [1] { Parameter #0 [ $purge_flags ] } } Method [ public method setLogger ] { - Parameters [1] { Parameter #0 [ $logger ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ $topic ] Parameter #1 [ $partition ] Parameter #2 [ &$low ] Parameter #3 [ &$high ] Parameter #4 [ $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ $topic_partitions ] Parameter #1 [ $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } } } Class [ class RdKafka\Exception extends Exception implements Throwable ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [4] { Property [ protected $message ] Property [ protected $code ] Property [ protected $file ] Property [ protected $line ] } - Methods [10] { Method [ public method __construct ] { - Parameters [3] { Parameter #0 [ $message ] Parameter #1 [ $code ] Parameter #2 [ $previous ] } } Method [ public method __wakeup ] { } Method [ final public method getMessage ] { } Method [ final public method getCode ] { } Method [ final public method getFile ] { } Method [ final public method getLine ] { } Method [ final public method getTrace ] { } Method [ final public method getPrevious ] { } Method [ final public method getTraceAsString ] { } Method [ public method __toString ] { } } } 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] { } } Method [ public method set ] { - Parameters [2] { Parameter #0 [ $name ] Parameter #1 [ $value ] } } Method [ public method setDefaultTopicConf ] { - Parameters [1] { Parameter #0 [ $topic_conf ] } } Method [ public method setErrorCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setDrMsgCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setStatsCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setRebalanceCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setConsumeCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setOffsetCommitCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } Method [ public method setLogCb ] { - Parameters [1] { Parameter #0 [ $callback ] } } } } 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] { } } Method [ public method set ] { - Parameters [2] { Parameter #0 [ $name ] Parameter #1 [ $value ] } } Method [ public method setPartitioner ] { - Parameters [1] { Parameter #0 [ $partitioner ] } } } } Class [ class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [8] { Property [ protected $message ] Property [ protected $code ] Property [ protected $file ] Property [ protected $line ] Property [ private $error_string ] Property [ private $isFatal ] Property [ private $isRetriable ] Property [ private $transactionRequiresAbort ] } - Methods [14] { Method [ public method __construct ] { - Parameters [6] { Parameter #0 [ $message ] Parameter #1 [ $code ] Parameter #2 [ $error_string ] Parameter #3 [ $isFatal ] Parameter #4 [ $isRetriable ] Parameter #5 [ $transactionRequiresAbort ] } } Method [ public method getErrorString ] { - Parameters [0] { } } Method [ public method isFatal ] { - Parameters [0] { } } Method [ public method isRetriable ] { - Parameters [0] { } } Method [ public method transactionRequiresAbort ] { - Parameters [0] { } } Method [ public method __wakeup ] { } Method [ final public method getMessage ] { } Method [ final public method getCode ] { } Method [ final public method getFile ] { } Method [ final public method getLine ] { } Method [ final public method getTrace ] { } Method [ final public method getPrevious ] { } Method [ final public method getTraceAsString ] { } Method [ public method __toString ] { } } } Class [ class RdKafka\KafkaConsumer ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [3] { Property [ private $error_cb ] Property [ private $rebalance_cb ] Property [ private $dr_msg_cb ] } - Methods [18] { Method [ public method __construct ] { - Parameters [1] { Parameter #0 [ $conf ] } } Method [ public method assign ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method getAssignment ] { - Parameters [0] { } } Method [ public method commit ] { - Parameters [1] { Parameter #0 [ $message_or_offsets ] } } Method [ public method close ] { - Parameters [0] { } } Method [ public method commitAsync ] { - Parameters [1] { Parameter #0 [ $message_or_offsets ] } } Method [ public method consume ] { - Parameters [1] { Parameter #0 [ $timeout_ms ] } } Method [ public method subscribe ] { - Parameters [1] { Parameter #0 [ $topics ] } } Method [ public method getSubscription ] { - Parameters [0] { } } Method [ public method unsubscribe ] { - Parameters [0] { } } Method [ public method getMetadata ] { - Parameters [3] { Parameter #0 [ $all_topics ] Parameter #1 [ $only_topic ] Parameter #2 [ $timeout_ms ] } } Method [ public method newTopic ] { - Parameters [2] { Parameter #0 [ $topic_name ] Parameter #1 [ $topic_conf ] } } Method [ public method getCommittedOffsets ] { - Parameters [2] { Parameter #0 [ $topic_partitions ] Parameter #1 [ $timeout_ms ] } } Method [ public method getOffsetPositions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method queryWatermarkOffsets ] { - Parameters [5] { Parameter #0 [ $topic ] Parameter #1 [ $partition ] Parameter #2 [ &$low ] Parameter #3 [ &$high ] Parameter #4 [ $timeout_ms ] } } Method [ public method offsetsForTimes ] { - Parameters [2] { Parameter #0 [ $topic_partitions ] Parameter #1 [ $timeout_ms ] } } Method [ public method pausePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } Method [ public method resumePartitions ] { - Parameters [1] { Parameter #0 [ $topic_partitions ] } } } } Class [ class RdKafka\Message ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [10] { Property [ public $err ] Property [ public $topic_name ] Property [ public $timestamp ] Property [ public $partition ] Property [ public $payload ] Property [ public $len ] Property [ public $key ] Property [ public $offset ] Property [ public $headers ] Property [ public $opaque ] } - Methods [1] { Method [ public method errstr ] { - Parameters [0] { } } } } Class [ class RdKafka\Metadata ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [4] { Method [ public method getOrigBrokerId ] { - Parameters [0] { } } Method [ public method getOrigBrokerName ] { - Parameters [0] { } } Method [ public method getBrokers ] { - Parameters [0] { } } Method [ public method getTopics ] { - Parameters [0] { } } } } Class [ class RdKafka\Metadata\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [3] { Method [ public method getTopic ] { - Parameters [0] { } } Method [ public method getPartitions ] { - Parameters [0] { } } Method [ public method getErr ] { - Parameters [0] { } } } } Class [ class RdKafka\Metadata\Broker ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [3] { Method [ public method getId ] { - Parameters [0] { } } Method [ public method getHost ] { - Parameters [0] { } } Method [ public method getPort ] { - Parameters [0] { } } } } Class [ class RdKafka\Metadata\Partition ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [5] { Method [ public method getId ] { - Parameters [0] { } } Method [ public method getErr ] { - Parameters [0] { } } Method [ public method getLeader ] { - Parameters [0] { } } Method [ public method getReplicas ] { - Parameters [0] { } } Method [ public method getIsrs ] { - Parameters [0] { } } } } 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] { } } Method [ public method current ] { - Parameters [0] { } } Method [ public method key ] { - Parameters [0] { } } Method [ public method next ] { - Parameters [0] { } } Method [ public method rewind ] { - Parameters [0] { } } Method [ public method valid ] { - Parameters [0] { } } } } Class [ class RdKafka\TopicPartition ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [8] { Method [ public method __construct ] { - Parameters [3] { Parameter #0 [ $topic ] Parameter #1 [ $partition ] Parameter #2 [ $offset ] } } Method [ public method getTopic ] { - Parameters [0] { } } Method [ public method setTopic ] { - Parameters [1] { Parameter #0 [ $topic_name ] } } Method [ public method getPartition ] { - Parameters [0] { } } Method [ public method setPartition ] { - Parameters [1] { Parameter #0 [ $partition ] } } Method [ public method getOffset ] { - Parameters [0] { } } Method [ public method setOffset ] { - Parameters [1] { Parameter #0 [ $offset ] } } Method [ public method getErr ] { - Parameters [0] { } } } } 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 [ $timeout_ms ] } } } } Class [ abstract class RdKafka\Topic ] { - Constants [0] { } - Static properties [0] { } - Static methods [0] { } - Properties [0] { } - Methods [1] { Method [ public method getName ] { - Parameters [0] { } } } } 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 [ $partition ] Parameter #1 [ $offset ] Parameter #2 [ $queue ] } } Method [ public method consumeCallback ] { - Parameters [3] { Parameter #0 [ $partition ] Parameter #1 [ $timeout_ms ] Parameter #2 [ $callback ] } } Method [ public method consumeStart ] { - Parameters [2] { Parameter #0 [ $partition ] Parameter #1 [ $offset ] } } Method [ public method consumeStop ] { - Parameters [1] { Parameter #0 [ $partition ] } } Method [ public method consume ] { - Parameters [2] { Parameter #0 [ $partition ] Parameter #1 [ $timeout_ms ] } } Method [ public method consumeBatch ] { - Parameters [3] { Parameter #0 [ $partition ] Parameter #1 [ $timeout_ms ] Parameter #2 [ $batch_size ] } } Method [ public method offsetStore ] { - Parameters [2] { Parameter #0 [ $partition ] Parameter #1 [ $offset ] } } Method [ public method getName ] { - Parameters [0] { } } } } 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 [ $partition ] Parameter #1 [ $offset ] } } Method [ public method getName ] { - Parameters [0] { } } } } 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 [ $partition ] Parameter #1 [ $msgflags ] Parameter #2 [ $payload ] Parameter #3 [ $key ] Parameter #4 [ $msg_opaque ] } } Method [ public method producev ] { - Parameters [7] { Parameter #0 [ $partition ] Parameter #1 [ $msgflags ] Parameter #2 [ $payload ] Parameter #3 [ $key ] Parameter #4 [ $headers ] Parameter #5 [ $timestamp_ms ] Parameter #6 [ $msg_opaque ] } } Method [ public method getName ] { - Parameters [0] { } } } } } }