duplicate v4

5 files changed, 1915 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..01f0400
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,9 @@
+clog
+package-*.xml
+*.tgz
+*.tar.bz2
+*.tar.gz
+*.tar.xz
+*.tar.xz.asc
+*.src.rpm
+*/*rpm
diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..13af741
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,4 @@
+SRCDIR := $(shell pwd)
+NAME := $(shell basename $(SRCDIR))
+include ../../../common/Makefile
+
diff --git a/PHPINFO b/PHPINFO
new file mode 100644
index 0000000..b6fa83b
--- /dev/null
+++ b/PHPINFO
@@ -0,0 +1,8 @@
+
+rdkafka
+
+rdkafka support => enabled
+version => 4.1.2
+build date => Dec 25 2020 00:00:00
+librdkafka version (runtime) => 1.5.3
+librdkafka version (build) => 1.5.3.255
diff --git a/REFLECTION b/REFLECTION
new file mode 100644
index 0000000..e66caae
--- /dev/null
+++ b/REFLECTION
@@ -0,0 +1,1568 @@
+Extension [ <persistent> extension #98 rdkafka version 4.1.2 ] {
+
+  - Constants [172] {
+    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 ] { 17105919 }
+    Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105919 }
+    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__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_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] {
+      }
+    }
+    Function [ <internal:rdkafka> function rd_kafka_err2str ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> $err ]
+      }
+    }
+    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno2err ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> $errnox ]
+      }
+    }
+    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno ] {
+
+      - Parameters [0] {
+      }
+    }
+    Function [ <internal:rdkafka> function rd_kafka_offset_tail ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> $cnt ]
+      }
+    }
+    Function [ <internal:rdkafka> function rd_kafka_thread_cnt ] {
+
+      - Parameters [0] {
+      }
+    }
+  }
+
+  - Classes [20] {
+    Class [ <internal:rdkafka> abstract class RdKafka ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [2] {
+        Property [ <default> private $error_cb ]
+        Property [ <default> private $dr_cb ]
+      }
+
+      - Methods [13] {
+        Method [ <internal:rdkafka> public method addBrokers ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $broker_list ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method metadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method setLogLevel ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $level ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method newTopic ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_name ]
+            Parameter #1 [ <optional> $topic_conf ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method outqLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method poll ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method setLogger ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $logger ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <optional> $partition ]
+            Parameter #2 [ <optional> &$low ]
+            Parameter #3 [ <optional> &$high ]
+            Parameter #4 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\Consumer extends RdKafka ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [15] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method newQueue ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $broker_list ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $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> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $level ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_name ]
+            Parameter #1 [ <optional> $topic_conf ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method poll ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $logger ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <optional> $partition ]
+            Parameter #2 [ <optional> &$low ]
+            Parameter #3 [ <optional> &$high ]
+            Parameter #4 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\Producer extends RdKafka ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [18] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method initTransactions ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method beginTransaction ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method commitTransaction ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method abortTransaction ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $broker_list ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $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> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $level ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_name ]
+            Parameter #1 [ <optional> $topic_conf ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method poll ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $logger ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <optional> $partition ]
+            Parameter #2 [ <optional> &$low ]
+            Parameter #3 [ <optional> &$high ]
+            Parameter #4 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\Exception extends Exception implements Throwable ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [4] {
+        Property [ <default> protected $message ]
+        Property [ <default> protected $code ]
+        Property [ <default> protected $file ]
+        Property [ <default> protected $line ]
+      }
+
+      - Methods [10] {
+        Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <optional> $message ]
+            Parameter #1 [ <optional> $code ]
+            Parameter #2 [ <optional> $previous ]
+          }
+        }
+
+        Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+        }
+      }
+    }
+
+    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> $name ]
+            Parameter #1 [ <required> $value ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setErrorCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setDrMsgCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setStatsCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setRebalanceCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setConsumeCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setOffsetCommitCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setLogCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $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> $name ]
+            Parameter #1 [ <required> $value ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setPartitioner ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $partitioner ]
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [8] {
+        Property [ <default> protected $message ]
+        Property [ <default> protected $code ]
+        Property [ <default> protected $file ]
+        Property [ <default> protected $line ]
+        Property [ <default> private $error_string ]
+        Property [ <default> private $isFatal ]
+        Property [ <default> private $isRetriable ]
+        Property [ <default> private $transactionRequiresAbort ]
+      }
+
+      - Methods [14] {
+        Method [ <internal:rdkafka, overwrites Exception, ctor> public method __construct ] {
+
+          - Parameters [6] {
+            Parameter #0 [ <required> $message ]
+            Parameter #1 [ <required> $code ]
+            Parameter #2 [ <required> $error_string ]
+            Parameter #3 [ <required> $isFatal ]
+            Parameter #4 [ <required> $isRetriable ]
+            Parameter #5 [ <required> $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 ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\KafkaConsumer ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [3] {
+        Property [ <default> private $error_cb ]
+        Property [ <default> private $rebalance_cb ]
+        Property [ <default> private $dr_msg_cb ]
+      }
+
+      - Methods [16] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method assign ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $topic_partitions ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getAssignment ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method commit ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $message_or_offsets ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method close ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method commitAsync ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $message_or_offsets ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consume ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method subscribe ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $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> $all_topics ]
+            Parameter #1 [ <required> $only_topic ]
+            Parameter #2 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method newTopic ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_name ]
+            Parameter #1 [ <optional> $topic_conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getCommittedOffsets ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getOffsetPositions ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_partitions ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <optional> $partition ]
+            Parameter #2 [ <optional> &$low ]
+            Parameter #3 [ <optional> &$high ]
+            Parameter #4 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\Message ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [9] {
+        Property [ <default> public $err ]
+        Property [ <default> public $topic_name ]
+        Property [ <default> public $timestamp ]
+        Property [ <default> public $partition ]
+        Property [ <default> public $payload ]
+        Property [ <default> public $len ]
+        Property [ <default> public $key ]
+        Property [ <default> public $offset ]
+        Property [ <default> public $headers ]
+      }
+
+      - 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 getPartitions ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getErr ] {
+
+          - 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 [7] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <required> $partition ]
+            Parameter #2 [ <optional> $offset ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getTopic ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setTopic ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_name ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getPartition ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setPartition ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $partition ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getOffset ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setOffset ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $offset ]
+          }
+        }
+      }
+    }
+
+    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> $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> $partition ]
+            Parameter #1 [ <required> $offset ]
+            Parameter #2 [ <required> $queue ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consumeCallback ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $timeout_ms ]
+            Parameter #2 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consumeStart ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $offset ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consumeStop ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $partition ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consume ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method consumeBatch ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $timeout_ms ]
+            Parameter #2 [ <required> $batch_size ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method offsetStore ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $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> $partition ]
+            Parameter #1 [ <required> $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 [4] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $msgflags ]
+            Parameter #2 [ <optional> $payload ]
+            Parameter #3 [ <optional> $key ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method producev ] {
+
+          - Parameters [6] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $msgflags ]
+            Parameter #2 [ <optional> $payload ]
+            Parameter #3 [ <optional> $key ]
+            Parameter #4 [ <optional> $headers ]
+            Parameter #5 [ <optional> $timestamp_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
+
+          - Parameters [0] {
+          }
+        }
+      }
+    }
+  }
+}
+
diff --git a/php-pecl-rdkafka5.spec b/php-pecl-rdkafka5.spec
new file mode 100644
index 0000000..9a04f52
--- /dev/null
+++ b/php-pecl-rdkafka5.spec
@@ -0,0 +1,326 @@
+# remirepo/fedora spec file for php-pecl-rdkafka4
+#
+# Copyright (c) 2015-2021 Remi Collet
+# License: CC-BY-SA
+# http://creativecommons.org/licenses/by-sa/4.0/
+#
+# Please, preserve the changelog entries
+#
+%if 0%{?scl:1}
+%global sub_prefix %{scl_prefix}
+%scl_package       php-pecl-rdkafka
+%endif
+
+%global with_zts   0%{!?_without_zts:%{?__ztsphp:1}}
+%global pecl_name  rdkafka
+%global with_tests %{?_without_tests:0}%{!?_without_tests:1}
+%global ini_name   40-%{pecl_name}.ini
+
+%global buildver %(pkg-config --silence-errors --modversion rdkafka 2>/dev/null || echo 65536)
+
+Summary:        Kafka client based on librdkafka
+Name:           %{?sub_prefix}php-pecl-%{pecl_name}4
+Version:        4.1.2
+Release:        1%{?dist}%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')}
+License:        MIT
+URL:            https://pecl.php.net/package/%{pecl_name}
+Source0:        https://pecl.php.net/get/%{pecl_name}-%{version}.tgz
+
+# git checkout master; git diff 4.1.2 -- *h *.c tests/ >/tmp/pp
+# + cleanup (version, produce_consume_transactional.phpt)
+Patch0:         %{pecl_name}-php8.patch
+
+BuildRequires:  %{?dtsprefix}gcc
+BuildRequires:  make
+BuildRequires:  librdkafka1php-devel
+BuildRequires:  %{?scl_prefix}php-devel >= 5.6
+BuildRequires:  %{?scl_prefix}php-pear
+
+Requires:       %{?scl_prefix}php(zend-abi) = %{php_zend_api}
+Requires:       %{?scl_prefix}php(api) = %{php_core_api}
+%{?_sclreq:Requires: %{?scl_prefix}runtime%{?_sclreq}%{?_isa}}
+Requires:       librdkafka1php%{?_isa}  >= %{buildver}
+
+Provides:       %{?scl_prefix}php-%{pecl_name}               = %{version}
+Provides:       %{?scl_prefix}php-%{pecl_name}%{?_isa}       = %{version}
+Provides:       %{?scl_prefix}php-pecl(%{pecl_name})         = %{version}
+Provides:       %{?scl_prefix}php-pecl(%{pecl_name})%{?_isa} = %{version}
+%if "%{?scl_prefix}" != "%{?sub_prefix}"
+Provides:       %{?scl_prefix}php-pecl-%{pecl_name}          = %{version}-%{release}
+Provides:       %{?scl_prefix}php-pecl-%{pecl_name}%{?_isa}  = %{version}-%{release}
+%endif
+
+%if 0%{?fedora} >= 31 || 0%{?rhel} >= 9 || "%{php_version}" > "7.4"
+Obsoletes:     %{?scl_prefix}php-pecl-%{pecl_name}          < 4
+Provides:      %{?scl_prefix}php-pecl-%{pecl_name}          = %{version}-%{release}
+Provides:      %{?scl_prefix}php-pecl-%{pecl_name}%{?_isa}  = %{version}-%{release}
+%else
+# A single version can be installed
+Conflicts:     %{?scl_prefix}php-pecl-%{pecl_name}          < 4
+%endif
+
+%if "%{?packager}" == "Remi Collet" && 0%{!?scl:1} && 0%{?rhel}
+# Other third party repo stuff
+%if "%{php_version}" > "7.3"
+Obsoletes:      php73-pecl-%{pecl_name} <= %{version}
+%endif
+%if "%{php_version}" > "7.4"
+Obsoletes:      php74-pecl-%{pecl_name} <= %{version}
+%endif
+%if "%{php_version}" > "8.0"
+Obsoletes:      php80-pecl-%{pecl_name} <= %{version}
+%endif
+%endif
+
+
+%description
+This extension is a librdkafka binding providing a working client for Kafka.
+
+Package built for PHP %(%{__php} -r 'echo PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')%{?scl: as Software Collection (%{scl} by %{?scl_vendor}%{!?scl_vendor:rh})}.
+
+
+%prep
+%setup -q -c
+mv %{pecl_name}-%{version} NTS
+
+# Don't install tests
+sed -e 's/role="test"/role="src"/' \
+    %{?_licensedir:-e '/LICENSE/s/role="doc"/role="src"/' } \
+    -i package.xml
+
+cd NTS
+%if "%{php_version}" > "8.0"
+%patch0 -p1 -b .up
+%endif
+
+# Sanity check, really often broken
+extver=$(sed -n '/#define PHP_RDKAFKA_VERSION/{s/.* "//;s/".*$//;p}' php_rdkafka.h)
+if test "x${extver}" != "x%{version}"; then
+   : Error: Upstream extension version is ${extver}, expecting %{version}.
+   exit 1
+fi
+cd ..
+
+%if %{with_zts}
+# Duplicate source tree for NTS / ZTS build
+cp -pr NTS ZTS
+%endif
+
+# Create configuration file
+cat > %{ini_name} << 'EOF'
+; Enable %{pecl_name} extension module
+extension=%{pecl_name}.so
+EOF
+
+
+%build
+%{?dtsenable}
+
+cd NTS
+%{_bindir}/phpize
+%configure \
+    --with-php-config=%{_bindir}/php-config \
+    --with-rdkafka
+make %{?_smp_mflags}
+
+%if %{with_zts}
+cd ../ZTS
+%{_bindir}/zts-phpize
+%configure \
+    --with-php-config=%{_bindir}/zts-php-config \
+    --with-rdkafka
+make %{?_smp_mflags}
+%endif
+
+
+%install
+%{?dtsenable}
+
+make -C NTS install INSTALL_ROOT=%{buildroot}
+
+# install config file
+install -D -m 644 %{ini_name} %{buildroot}%{php_inidir}/%{ini_name}
+
+# Install XML package description
+install -D -m 644 package.xml %{buildroot}%{pecl_xmldir}/%{name}.xml
+
+%if %{with_zts}
+make -C ZTS install INSTALL_ROOT=%{buildroot}
+
+install -D -m 644 %{ini_name} %{buildroot}%{php_ztsinidir}/%{ini_name}
+%endif
+
+# Documentation
+for i in $(grep 'role="doc"' package.xml | sed -e 's/^.*name="//;s/".*$//')
+do install -Dpm 644 NTS/$i %{buildroot}%{pecl_docdir}/%{pecl_name}/$i
+done
+
+
+%if 0%{?fedora} < 24 && 0%{?rhel} < 8
+# when pear installed alone, after us
+%triggerin -- %{?scl_prefix}php-pear
+if [ -x %{__pecl} ] ; then
+    %{pecl_install} %{pecl_xmldir}/%{name}.xml >/dev/null || :
+fi
+
+# posttrans as pear can be installed after us
+%posttrans
+if [ -x %{__pecl} ] ; then
+    %{pecl_install} %{pecl_xmldir}/%{name}.xml >/dev/null || :
+fi
+
+%postun
+if [ $1 -eq 0 -a -x %{__pecl} ] ; then
+    %{pecl_uninstall} %{pecl_name} >/dev/null || :
+fi
+%endif
+
+
+%check
+cd NTS
+: Minimal load test for NTS extension
+%{__php} --no-php-ini \
+    --define extension=%{buildroot}%{php_extdir}/%{pecl_name}.so \
+    --modules | grep '^%{pecl_name}$'
+
+%if %{with_zts}
+cd ../ZTS
+: Minimal load test for ZTS extension
+%{__ztsphp} --no-php-ini \
+    --define extension=%{buildroot}%{php_ztsextdir}/%{pecl_name}.so \
+    --modules | grep '^%{pecl_name}$'
+%endif
+
+
+%files
+%{?_licensedir:%license NTS/LICENSE}
+%doc %{pecl_docdir}/%{pecl_name}
+%{pecl_xmldir}/%{name}.xml
+
+%config(noreplace) %{php_inidir}/%{ini_name}
+%{php_extdir}/%{pecl_name}.so
+
+%if %{with_zts}
+%config(noreplace) %{php_ztsinidir}/%{ini_name}
+%{php_ztsextdir}/%{pecl_name}.so
+%endif
+
+
+%changelog
+* Fri Dec 25 2020 Remi Collet <remi@remirepo.net> - 4.1.2-1
+- update to 4.1.2
+
+* Tue Dec  8 2020 Remi Collet <remi@remirepo.net> - 4.1.1-1
+- update to 4.1.1
+
+* Mon Dec  7 2020 Remi Collet <remi@remirepo.net> - 4.1.0-2
+- add upstream patches for PHP 8
+
+* Mon Dec  7 2020 Remi Collet <remi@remirepo.net> - 4.1.0-1
+- update to 4.1.0
+
+* Thu Oct  8 2020 Remi Collet <remi@remirepo.net> - 4.0.4-1
+- update to 4.0.4
+
+* Sun Jun 21 2020 Remi Collet <remi@remirepo.net> - 4.0.3-2
+- rebuild using librdkafka1php 1.4.4
+
+* Fri Feb  7 2020 Remi Collet <remi@remirepo.net> - 4.0.3-1
+- update to 4.0.3
+
+* Mon Dec 16 2019 Remi Collet <remi@remirepo.net> - 4.0.2-1
+- update to 4.0.2
+
+* Mon Dec  9 2019 Remi Collet <remi@remirepo.net> - 4.0.1-1
+- update to 4.0.1
+
+* Sat Oct  5 2019 Remi Collet <remi@remirepo.net> - 4.0.0-1
+- update to 4.0.0
+- rename to php-pecl-rdkafka4
+- raise dependency on librdkafka 0.11
+
+* Tue Sep 03 2019 Remi Collet <remi@remirepo.net> - 3.1.2-2
+- rebuild for 7.4.0RC1
+
+* Tue Jul  9 2019 Remi Collet <remi@remirepo.net> - 3.1.2-1
+- update to 3.1.2
+
+* Mon Jul  8 2019 Remi Collet <remi@remirepo.net> - 3.1.1-2
+- add upstream patch to fix PHP 5.6 build
+
+* Wed Jul  3 2019 Remi Collet <remi@remirepo.net> - 3.1.1-1
+- update to 3.1.1
+- open https://github.com/arnaud-lb/php-rdkafka/issues/235
+  broken build with PHP 5.6 (ZVAL_DEREF)
+
+* Tue Jun 25 2019 Remi Collet <remi@remirepo.net> - 3.1.0-2
+- rebuild with librdkafka 0.11 in EL-8
+
+* Thu Apr 18 2019 Remi Collet <remi@remirepo.net> - 3.1.0-1
+- update to 3.1.0
+- raise dependency on PHP 5.6
+
+* Thu Aug 16 2018 Remi Collet <remi@remirepo.net> - 3.0.5-3
+- rebuild for 7.3.0beta2 new ABI
+
+* Wed Jul 18 2018 Remi Collet <remi@remirepo.net> - 3.0.5-2
+- rebuild for 7.3.0alpha4 new ABI
+
+* Mon Nov 20 2017 Remi Collet <remi@remirepo.net> - 3.0.5-1
+- Update to 3.0.5
+
+* Wed Aug 23 2017 Remi Collet <remi@remirepo.net> - 3.0.4-2
+- EL-7 rebuild using librdkafka in EPEL
+
+* Wed Aug 16 2017 Remi Collet <remi@remirepo.net> - 3.0.4-1
+- Update to 3.0.4
+
+* Tue Jul 18 2017 Remi Collet <remi@remirepo.net> - 3.0.3-4
+- rebuild for PHP 7.2.0beta1 new API
+
+* Wed Jun 21 2017 Remi Collet <remi@remirepo.net> - 3.0.3-2
+- rebuild for 7.2.0alpha2
+
+* Mon May 29 2017 Remi Collet <remi@remirepo.net> - 3.0.3-1
+- Update to 3.0.3
+
+* Wed May 24 2017 Remi Collet <remi@remirepo.net> - 3.0.2-1
+- Update to 3.0.2 (stable)
+
+* Sat Jan 28 2017 Remi Collet <remi@fedoraproject.org> - 3.0.1-1
+- Update to 3.0.1
+
+* Mon Dec 19 2016 Remi Collet <remi@fedoraproject.org> - 3.0.0-1
+- update to 3.0.0 (php 5 and 7, stable)
+- open https://github.com/arnaud-lb/php-rdkafka/issues/98 failed build
+  fixed by https://github.com/arnaud-lb/php-rdkafka/pull/99
+
+* Thu Dec  1 2016 Remi Collet <remi@fedoraproject.org> - 2.0.1-2
+- rebuild with PHP 7.1.0 GA
+
+* Mon Nov 28 2016 Remi Collet <remi@fedoraproject.org> - 2.0.1-1
+- Update to 2.0.1
+
+* Wed Sep 14 2016 Remi Collet <remi@fedoraproject.org> - 2.0.0-2
+- rebuild for PHP 7.1 new API version
+
+* Fri Sep 09 2016 Remi Collet <remi@fedoraproject.org> - 2.0.0-1
+- Update to 2.0.0 (php 7)
+- open https://github.com/arnaud-lb/php-rdkafka/issues/71
+
+* Fri Sep 09 2016 Remi Collet <remi@fedoraproject.org> - 1.0.0-1
+- Update to 1.0.0 (php 5)
+
+* Tue Mar  8 2016 Remi Collet <remi@fedoraproject.org> - 0.9.1-2
+- adapt for F24
+
+* Mon Jan 11 2016 Remi Collet <remi@fedoraproject.org> - 0.9.1-1
+- Update to 0.9.1 (beta)
+
+* Sat Jan 09 2016 Remi Collet <remi@fedoraproject.org> - 0.9.0-1
+- Update to 0.9.0 (beta)
+
+* Thu May 14 2015 Remi Collet <remi@fedoraproject.org> - 0.0.2-1
+- initial package, version 0.0.2 (alpha)
+- open https://github.com/arnaud-lb/php-rdkafka/pull/5 - ZTS build
+- open https://github.com/arnaud-lb/php-rdkafka/pull/4 - License