Extension [ <persistent> extension #97 rdkafka version 6.0.0RC2 ] {

  - 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 [ <internal:rdkafka> function rd_kafka_get_err_descs ] {

      - Parameters [0] {
      }
      - Return [ array ]
    }
    Function [ <internal:rdkafka> function rd_kafka_err2name ] {

      - Parameters [1] {
        Parameter #0 [ <required> int $err ]
      }
      - Return [ ?string ]
    }
    Function [ <internal:rdkafka> function rd_kafka_err2str ] {

      - Parameters [1] {
        Parameter #0 [ <required> int $err ]
      }
      - Return [ ?string ]
    }
    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno2err ] {

      - Parameters [1] {
        Parameter #0 [ <required> int $errnox ]
      }
      - Return [ int ]
    }
    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno ] {

      - Parameters [0] {
      }
      - Return [ int ]
    }
    Function [ <internal:rdkafka> function rd_kafka_offset_tail ] {

      - Parameters [1] {
        Parameter #0 [ <required> int $cnt ]
      }
      - Return [ int ]
    }
    Function [ <internal:rdkafka> function rd_kafka_thread_cnt ] {

      - Parameters [0] {
      }
      - Return [ int ]
    }
  }

  - Classes [20] {
    Class [ <internal:rdkafka> 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 [ <internal:rdkafka, ctor> private method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method addBrokers ] {

          - Parameters [1] {
            Parameter #0 [ <required> string $broker_list ]
          }
        }

        Method [ <internal:rdkafka> public method getMetadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method getOutQLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal, deprecated:rdkafka> public method metadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal, deprecated:rdkafka> public method setLogLevel ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $level ]
          }
        }

        Method [ <internal:rdkafka> public method newTopic ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $topic_name ]
            Parameter #1 [ <optional> ?RdKafka\Conf $topic_conf = null ]
          }
        }

        Method [ <internal, deprecated:rdkafka> public method outqLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method poll ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method flush ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method purge ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $purge_flags ]
          }
        }

        Method [ <internal, deprecated:rdkafka> public method setLogger ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $logger ]
          }
        }

        Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {

          - Parameters [5] {
            Parameter #0 [ <required> string $topic ]
            Parameter #1 [ <required> int $partition ]
            Parameter #2 [ <required> int &$low ]
            Parameter #3 [ <required> int &$high ]
            Parameter #4 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method offsetsForTimes ] {

          - Parameters [2] {
            Parameter #0 [ <required> array $topic_partitions ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method pausePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }

        Method [ <internal:rdkafka> public method resumePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Consumer extends RdKafka ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [17] {
        Method [ <internal:rdkafka, overwrites RdKafka, ctor> public method __construct ] {

          - Parameters [1] {
            Parameter #0 [ <optional> ?RdKafka\Conf $conf = null ]
          }
        }

        Method [ <internal:rdkafka> public method newQueue ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {

          - Parameters [1] {
            Parameter #0 [ <required> string $broker_list ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $level ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $topic_name ]
            Parameter #1 [ <optional> ?RdKafka\Conf $topic_conf = null ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method poll ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $purge_flags ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $logger ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] {

          - Parameters [5] {
            Parameter #0 [ <required> string $topic ]
            Parameter #1 [ <required> int $partition ]
            Parameter #2 [ <required> int &$low ]
            Parameter #3 [ <required> int &$high ]
            Parameter #4 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {

          - Parameters [2] {
            Parameter #0 [ <required> array $topic_partitions ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Producer extends RdKafka ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [20] {
        Method [ <internal:rdkafka, overwrites RdKafka, ctor> public method __construct ] {

          - Parameters [1] {
            Parameter #0 [ <optional> ?RdKafka\Conf $conf = null ]
          }
        }

        Method [ <internal:rdkafka> public method initTransactions ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method beginTransaction ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method commitTransaction ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method abortTransaction ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {

          - Parameters [1] {
            Parameter #0 [ <required> string $broker_list ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> ?RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $level ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $topic_name ]
            Parameter #1 [ <optional> ?RdKafka\Conf $topic_conf = null ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method poll ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $purge_flags ]
          }
        }

        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $logger ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] {

          - Parameters [5] {
            Parameter #0 [ <required> string $topic ]
            Parameter #1 [ <required> int $partition ]
            Parameter #2 [ <required> int &$low ]
            Parameter #3 [ <required> int &$high ]
            Parameter #4 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {

          - Parameters [2] {
            Parameter #0 [ <required> array $topic_partitions ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method pausePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka> public method resumePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Exception extends Exception implements Stringable, Throwable ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [4] {
        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> 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 Stringable> public method __toString ] {

          - Parameters [0] {
          }
          - Return [ string ]
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Conf ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [11] {
        Method [ <internal:rdkafka, ctor> public method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method dump ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method set ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $name ]
            Parameter #1 [ <required> string $value ]
          }
        }

        Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] {

          - Parameters [1] {
            Parameter #0 [ <required> RdKafka\TopicConf $topic_conf ]
          }
        }

        Method [ <internal:rdkafka> public method setErrorCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setDrMsgCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setStatsCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setRebalanceCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setConsumeCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setOffsetCommitCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method setLogCb ] {

          - Parameters [1] {
            Parameter #0 [ <required> callable $callback ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\TopicConf ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [4] {
        Method [ <internal:rdkafka, ctor> public method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method dump ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method set ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $name ]
            Parameter #1 [ <required> string $value ]
          }
        }

        Method [ <internal:rdkafka> public method setPartitioner ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $partitioner ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable, Stringable ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [8] {
        Property [ protected $message = '' ]
        Property [ protected $code = 0 ]
        Property [ protected $file = NULL ]
        Property [ protected $line = NULL ]
        Property [ private string $error_string ]
        Property [ private bool $isFatal ]
        Property [ private bool $isRetriable ]
        Property [ private bool $transactionRequiresAbort ]
      }

      - Methods [14] {
        Method [ <internal:rdkafka, overwrites Exception, ctor> public method __construct ] {

          - Parameters [6] {
            Parameter #0 [ <required> string $message ]
            Parameter #1 [ <required> int $code ]
            Parameter #2 [ <required> string $error_string ]
            Parameter #3 [ <required> bool $isFatal ]
            Parameter #4 [ <required> bool $isRetriable ]
            Parameter #5 [ <required> bool $transactionRequiresAbort ]
          }
        }

        Method [ <internal:rdkafka> public method getErrorString ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method isFatal ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method isRetriable ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method transactionRequiresAbort ] {

          - Parameters [0] {
          }
        }

        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 Stringable> public method __toString ] {

          - Parameters [0] {
          }
          - Return [ string ]
        }
      }
    }

    Class [ <internal:rdkafka> 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 [ <internal:rdkafka, ctor> public method __construct ] {

          - Parameters [1] {
            Parameter #0 [ <required> RdKafka\Conf $conf ]
          }
        }

        Method [ <internal:rdkafka> public method assign ] {

          - Parameters [1] {
            Parameter #0 [ <optional> ?array $topic_partitions = null ]
          }
        }

        Method [ <internal:rdkafka> public method getAssignment ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method commit ] {

          - Parameters [1] {
            Parameter #0 [ <optional> RdKafka\Message|array|null $message_or_offsets = null ]
          }
        }

        Method [ <internal:rdkafka> public method close ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method commitAsync ] {

          - Parameters [1] {
            Parameter #0 [ <optional> RdKafka\Message|array|null $message_or_offsets = null ]
          }
        }

        Method [ <internal:rdkafka> public method consume ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method subscribe ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topics ]
          }
        }

        Method [ <internal:rdkafka> public method getSubscription ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method unsubscribe ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getMetadata ] {

          - Parameters [3] {
            Parameter #0 [ <required> bool $all_topics ]
            Parameter #1 [ <required> RdKafka\Topic $only_topic ]
            Parameter #2 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method newTopic ] {

          - Parameters [2] {
            Parameter #0 [ <required> string $topic_name ]
            Parameter #1 [ <optional> ?RdKafka\Conf $topic_conf = null ]
          }
        }

        Method [ <internal:rdkafka> public method getCommittedOffsets ] {

          - Parameters [2] {
            Parameter #0 [ <required> array $topic_partitions ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method getOffsetPositions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }

        Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {

          - Parameters [5] {
            Parameter #0 [ <required> string $topic ]
            Parameter #1 [ <required> int $partition ]
            Parameter #2 [ <required> int &$low ]
            Parameter #3 [ <required> int &$high ]
            Parameter #4 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method offsetsForTimes ] {

          - Parameters [2] {
            Parameter #0 [ <required> array $topic_partitions ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method pausePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }

        Method [ <internal:rdkafka> public method resumePartitions ] {

          - Parameters [1] {
            Parameter #0 [ <required> array $topic_partitions ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> 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 [ <internal:rdkafka> public method errstr ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Metadata ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [4] {
        Method [ <internal:rdkafka> public method getOrigBrokerId ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getOrigBrokerName ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getBrokers ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getTopics ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Metadata\Topic ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [3] {
        Method [ <internal:rdkafka> public method getTopic ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getErr ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getPartitions ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Metadata\Broker ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [3] {
        Method [ <internal:rdkafka> public method getId ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getHost ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getPort ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Metadata\Partition ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [5] {
        Method [ <internal:rdkafka> public method getId ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getErr ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getLeader ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getReplicas ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method getIsrs ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> <iterateable> class RdKafka\Metadata\Collection implements Countable, Iterator, Traversable ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [6] {
        Method [ <internal:rdkafka, prototype Countable> public method count ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, prototype Iterator> public method current ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, prototype Iterator> public method key ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, prototype Iterator> public method next ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, prototype Iterator> public method rewind ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka, prototype Iterator> public method valid ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\TopicPartition ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [8] {
        Method [ <internal:rdkafka, ctor> public method __construct ] {

          - Parameters [3] {
            Parameter #0 [ <required> string $topic ]
            Parameter #1 [ <required> int $partition ]
            Parameter #2 [ <optional> int $offset = 0 ]
          }
        }

        Method [ <internal:rdkafka> public method getTopic ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method setTopic ] {

          - Parameters [1] {
            Parameter #0 [ <required> string $topic_name ]
          }
        }

        Method [ <internal:rdkafka> public method getPartition ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method setPartition ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $partition ]
          }
        }

        Method [ <internal:rdkafka> public method getOffset ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method setOffset ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $offset ]
          }
        }

        Method [ <internal:rdkafka> public method getErr ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\Queue ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [2] {
        Method [ <internal:rdkafka, ctor> private method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method consume ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $timeout_ms ]
          }
        }
      }
    }

    Class [ <internal:rdkafka> abstract class RdKafka\Topic ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [1] {
        Method [ <internal:rdkafka> public method getName ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\ConsumerTopic extends RdKafka\Topic ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [9] {
        Method [ <internal:rdkafka, ctor> private method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method consumeQueueStart ] {

          - Parameters [3] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $offset ]
            Parameter #2 [ <required> RdKafka\Queue $queue ]
          }
        }

        Method [ <internal:rdkafka> public method consumeCallback ] {

          - Parameters [3] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $timeout_ms ]
            Parameter #2 [ <required> callable $callback ]
          }
        }

        Method [ <internal:rdkafka> public method consumeStart ] {

          - Parameters [2] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $offset ]
          }
        }

        Method [ <internal:rdkafka> public method consumeStop ] {

          - Parameters [1] {
            Parameter #0 [ <required> int $partition ]
          }
        }

        Method [ <internal:rdkafka> public method consume ] {

          - Parameters [2] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $timeout_ms ]
          }
        }

        Method [ <internal:rdkafka> public method consumeBatch ] {

          - Parameters [3] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $timeout_ms ]
            Parameter #2 [ <required> int $batch_size ]
          }
        }

        Method [ <internal:rdkafka> public method offsetStore ] {

          - Parameters [2] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $offset ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\KafkaConsumerTopic extends RdKafka\Topic ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [3] {
        Method [ <internal:rdkafka, ctor> private method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method offsetStore ] {

          - Parameters [2] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $offset ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {

          - Parameters [0] {
          }
        }
      }
    }

    Class [ <internal:rdkafka> class RdKafka\ProducerTopic extends RdKafka\Topic ] {

      - Constants [0] {
      }

      - Static properties [0] {
      }

      - Static methods [0] {
      }

      - Properties [0] {
      }

      - Methods [4] {
        Method [ <internal:rdkafka, ctor> private method __construct ] {

          - Parameters [0] {
          }
        }

        Method [ <internal:rdkafka> public method produce ] {

          - Parameters [5] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $msgflags ]
            Parameter #2 [ <optional> ?string $payload = null ]
            Parameter #3 [ <optional> ?string $key = null ]
            Parameter #4 [ <optional> ?string $msg_opaque = null ]
          }
        }

        Method [ <internal:rdkafka> public method producev ] {

          - Parameters [7] {
            Parameter #0 [ <required> int $partition ]
            Parameter #1 [ <required> int $msgflags ]
            Parameter #2 [ <optional> ?string $payload = null ]
            Parameter #3 [ <optional> ?string $key = null ]
            Parameter #4 [ <optional> ?array $headers = null ]
            Parameter #5 [ <optional> ?int $timestamp_ms = null ]
            Parameter #6 [ <optional> ?string $msg_opaque = null ]
          }
        }

        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {

          - Parameters [0] {
          }
        }
      }
    }
  }
}