diff --git a/dictionaries/CallMap.php b/dictionaries/CallMap.php
index 782ed5d8f..ccefe6a0b 100644
--- a/dictionaries/CallMap.php
+++ b/dictionaries/CallMap.php
@@ -9696,97 +9696,6 @@ return [
 'RarException::setUsingExceptions' => ['RarEntry', 'using_exceptions'=>'bool'],
 'rawurldecode' => ['string', 'string'=>'string'],
 'rawurlencode' => ['string', 'string'=>'string'],
-'rd_kafka_err2str' => ['string', 'err'=>'int'],
-'rd_kafka_errno' => ['int'],
-'rd_kafka_errno2err' => ['int', 'errnox'=>'int'],
-'rd_kafka_offset_tail' => ['int', 'cnt'=>'int'],
-'RdKafka::addBrokers' => ['int', 'broker_list'=>'string'],
-'RdKafka::flush' => ['int', 'timeout_ms'=>'int'],
-'RdKafka::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-'RdKafka::getOutQLen' => ['int'],
-'RdKafka::newQueue' => ['RdKafka\Queue'],
-'RdKafka::newTopic' => ['RdKafka\Topic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-'RdKafka::poll' => ['void', 'timeout_ms'=>'int'],
-'RdKafka::setLogLevel' => ['void', 'level'=>'int'],
-'RdKafka\Conf::dump' => ['array<string, string>'],
-'RdKafka\Conf::set' => ['void', 'name'=>'string', 'value'=>'string'],
-'RdKafka\Conf::setDefaultTopicConf' => ['void', 'topic_conf'=>'RdKafka\TopicConf'],
-'RdKafka\Conf::setDrMsgCb' => ['void', 'callback'=>'callable'],
-'RdKafka\Conf::setErrorCb' => ['void', 'callback'=>'callable'],
-'RdKafka\Conf::setRebalanceCb' => ['void', 'callback'=>'callable'],
-'RdKafka\Conf::setStatsCb' => ['void', 'callback'=>'callable'],
-'RdKafka\Consumer::__construct' => ['void', 'conf='=>'?RdKafka\Conf'],
-'RdKafka\Consumer::addBrokers' => ['int', 'broker_list'=>'string'],
-'RdKafka\Consumer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-'RdKafka\Consumer::getOutQLen' => ['int'],
-'RdKafka\Consumer::newQueue' => ['RdKafka\Queue'],
-'RdKafka\Consumer::newTopic' => ['RdKafka\ConsumerTopic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-'RdKafka\Consumer::poll' => ['void', 'timeout_ms'=>'int'],
-'RdKafka\Consumer::setLogLevel' => ['void', 'level'=>'int'],
-'RdKafka\ConsumerTopic::__construct' => ['void'],
-'RdKafka\ConsumerTopic::consume' => ['RdKafka\Message', 'partition'=>'int', 'timeout_ms'=>'int'],
-'RdKafka\ConsumerTopic::consumeQueueStart' => ['void', 'partition'=>'int', 'offset'=>'int', 'queue'=>'RdKafka\Queue'],
-'RdKafka\ConsumerTopic::consumeStart' => ['void', 'partition'=>'int', 'offset'=>'int'],
-'RdKafka\ConsumerTopic::consumeStop' => ['void', 'partition'=>'int'],
-'RdKafka\ConsumerTopic::getName' => ['string'],
-'RdKafka\ConsumerTopic::offsetStore' => ['void', 'partition'=>'int', 'offset'=>'int'],
-'RdKafka\KafkaConsumer::__construct' => ['void', 'conf'=>'RdKafka\Conf'],
-'RdKafka\KafkaConsumer::assign' => ['void', 'topic_partitions='=>'RdKafka\TopicPartition[]|null'],
-'RdKafka\KafkaConsumer::commit' => ['void', 'message_or_offsets='=>'RdKafka\Message|RdKafka\TopicPartition[]|null'],
-'RdKafka\KafkaConsumer::commitAsync' => ['void', 'message_or_offsets='=>'RdKafka\Message|RdKafka\TopicPartition[]|null'],
-'RdKafka\KafkaConsumer::consume' => ['RdKafka\Message', 'timeout_ms'=>'int'],
-'RdKafka\KafkaConsumer::getAssignment' => ['RdKafka\TopicPartition[]'],
-'RdKafka\KafkaConsumer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\KafkaConsumerTopic', 'timeout_ms'=>'int'],
-'RdKafka\KafkaConsumer::getSubscription' => ['array'],
-'RdKafka\KafkaConsumer::subscribe' => ['void', 'topics'=>'array'],
-'RdKafka\KafkaConsumer::unsubscribe' => ['void'],
-'RdKafka\KafkaConsumerTopic::getName' => ['string'],
-'RdKafka\KafkaConsumerTopic::offsetStore' => ['void', 'partition'=>'int', 'offset'=>'int'],
-'RdKafka\Message::errstr' => ['string'],
-'RdKafka\Metadata::getBrokers' => ['RdKafka\Metadata\Collection'],
-'RdKafka\Metadata::getOrigBrokerId' => ['int'],
-'RdKafka\Metadata::getOrigBrokerName' => ['string'],
-'RdKafka\Metadata::getTopics' => ['RdKafka\Metadata\Collection|RdKafka\Metadata\Topic[]'],
-'RdKafka\Metadata\Collection::__construct' => ['void'],
-'RdKafka\Metadata\Collection::count' => ['int'],
-'RdKafka\Metadata\Collection::current' => ['mixed'],
-'RdKafka\Metadata\Collection::key' => ['mixed'],
-'RdKafka\Metadata\Collection::next' => ['void'],
-'RdKafka\Metadata\Collection::rewind' => ['void'],
-'RdKafka\Metadata\Collection::valid' => ['bool'],
-'RdKafka\Metadata\Partition::getErr' => ['mixed'],
-'RdKafka\Metadata\Partition::getId' => ['int'],
-'RdKafka\Metadata\Partition::getIsrs' => ['mixed'],
-'RdKafka\Metadata\Partition::getLeader' => ['mixed'],
-'RdKafka\Metadata\Partition::getReplicas' => ['mixed'],
-'RdKafka\Metadata\Topic::getErr' => ['mixed'],
-'RdKafka\Metadata\Topic::getPartitions' => ['RdKafka\Metadata\Partition[]'],
-'RdKafka\Metadata\Topic::getTopic' => ['string'],
-'RdKafka\Producer::__construct' => ['void', 'conf='=>'?RdKafka\Conf'],
-'RdKafka\Producer::addBrokers' => ['int', 'broker_list'=>'string'],
-'RdKafka\Producer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-'RdKafka\Producer::getOutQLen' => ['int'],
-'RdKafka\Producer::newQueue' => ['RdKafka\Queue'],
-'RdKafka\Producer::newTopic' => ['RdKafka\ProducerTopic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-'RdKafka\Producer::poll' => ['void', 'timeout_ms'=>'int'],
-'RdKafka\Producer::setLogLevel' => ['void', 'level'=>'int'],
-'RdKafka\ProducerTopic::__construct' => ['void'],
-'RdKafka\ProducerTopic::getName' => ['string'],
-'RdKafka\ProducerTopic::produce' => ['void', 'partition'=>'int', 'msgflags'=>'int', 'payload'=>'string', 'key='=>'?string'],
-'RdKafka\ProducerTopic::producev' => ['void', 'partition'=>'int', 'msgflags'=>'int', 'payload'=>'string', 'key='=>'?string', 'headers='=>'?array<string, string>', 'timestamp_ms='=>'?int', 'opaque='=>'?string'],
-'RdKafka\Queue::__construct' => ['void'],
-'RdKafka\Queue::consume' => ['?RdKafka\Message', 'timeout_ms'=>'string'],
-'RdKafka\Topic::getName' => ['string'],
-'RdKafka\TopicConf::dump' => ['array<string, string>'],
-'RdKafka\TopicConf::set' => ['void', 'name'=>'string', 'value'=>'string'],
-'RdKafka\TopicConf::setPartitioner' => ['void', 'partitioner'=>'int'],
-'RdKafka\TopicPartition::__construct' => ['void', 'topic'=>'string', 'partition'=>'int', 'offset='=>'int'],
-'RdKafka\TopicPartition::getOffset' => ['int'],
-'RdKafka\TopicPartition::getPartition' => ['int'],
-'RdKafka\TopicPartition::getTopic' => ['string'],
-'RdKafka\TopicPartition::setOffset' => ['void', 'offset'=>'string'],
-'RdKafka\TopicPartition::setPartition' => ['void', 'partition'=>'string'],
-'RdKafka\TopicPartition::setTopic' => ['void', 'topic_name'=>'string'],
 'readdir' => ['string|false', 'dir_handle='=>'resource'],
 'readfile' => ['int|false', 'filename'=>'string', 'use_include_path='=>'bool', 'context='=>'resource'],
 'readgzfile' => ['int|false', 'filename'=>'string', 'use_include_path='=>'int'],
diff --git a/dictionaries/CallMap_historical.php b/dictionaries/CallMap_historical.php
index 5ff4033af..73ce32e3d 100644
--- a/dictionaries/CallMap_historical.php
+++ b/dictionaries/CallMap_historical.php
@@ -5070,93 +5070,6 @@ return [
     'RarException::getTraceAsString' => ['string'],
     'RarException::isUsingExceptions' => ['bool'],
     'RarException::setUsingExceptions' => ['RarEntry', 'using_exceptions'=>'bool'],
-    'RdKafka::addBrokers' => ['int', 'broker_list'=>'string'],
-    'RdKafka::flush' => ['int', 'timeout_ms'=>'int'],
-    'RdKafka::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-    'RdKafka::getOutQLen' => ['int'],
-    'RdKafka::newQueue' => ['RdKafka\Queue'],
-    'RdKafka::newTopic' => ['RdKafka\Topic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-    'RdKafka::poll' => ['void', 'timeout_ms'=>'int'],
-    'RdKafka::setLogLevel' => ['void', 'level'=>'int'],
-    'RdKafka\Conf::dump' => ['array<string, string>'],
-    'RdKafka\Conf::set' => ['void', 'name'=>'string', 'value'=>'string'],
-    'RdKafka\Conf::setDefaultTopicConf' => ['void', 'topic_conf'=>'RdKafka\TopicConf'],
-    'RdKafka\Conf::setDrMsgCb' => ['void', 'callback'=>'callable'],
-    'RdKafka\Conf::setErrorCb' => ['void', 'callback'=>'callable'],
-    'RdKafka\Conf::setRebalanceCb' => ['void', 'callback'=>'callable'],
-    'RdKafka\Conf::setStatsCb' => ['void', 'callback'=>'callable'],
-    'RdKafka\Consumer::__construct' => ['void', 'conf='=>'?RdKafka\Conf'],
-    'RdKafka\Consumer::addBrokers' => ['int', 'broker_list'=>'string'],
-    'RdKafka\Consumer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-    'RdKafka\Consumer::getOutQLen' => ['int'],
-    'RdKafka\Consumer::newQueue' => ['RdKafka\Queue'],
-    'RdKafka\Consumer::newTopic' => ['RdKafka\ConsumerTopic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-    'RdKafka\Consumer::poll' => ['void', 'timeout_ms'=>'int'],
-    'RdKafka\Consumer::setLogLevel' => ['void', 'level'=>'int'],
-    'RdKafka\ConsumerTopic::__construct' => ['void'],
-    'RdKafka\ConsumerTopic::consume' => ['RdKafka\Message', 'partition'=>'int', 'timeout_ms'=>'int'],
-    'RdKafka\ConsumerTopic::consumeQueueStart' => ['void', 'partition'=>'int', 'offset'=>'int', 'queue'=>'RdKafka\Queue'],
-    'RdKafka\ConsumerTopic::consumeStart' => ['void', 'partition'=>'int', 'offset'=>'int'],
-    'RdKafka\ConsumerTopic::consumeStop' => ['void', 'partition'=>'int'],
-    'RdKafka\ConsumerTopic::getName' => ['string'],
-    'RdKafka\ConsumerTopic::offsetStore' => ['void', 'partition'=>'int', 'offset'=>'int'],
-    'RdKafka\KafkaConsumer::__construct' => ['void', 'conf'=>'RdKafka\Conf'],
-    'RdKafka\KafkaConsumer::assign' => ['void', 'topic_partitions='=>'RdKafka\TopicPartition[]|null'],
-    'RdKafka\KafkaConsumer::commit' => ['void', 'message_or_offsets='=>'RdKafka\Message|RdKafka\TopicPartition[]|null'],
-    'RdKafka\KafkaConsumer::commitAsync' => ['void', 'message_or_offsets='=>'RdKafka\Message|RdKafka\TopicPartition[]|null'],
-    'RdKafka\KafkaConsumer::consume' => ['RdKafka\Message', 'timeout_ms'=>'int'],
-    'RdKafka\KafkaConsumer::getAssignment' => ['RdKafka\TopicPartition[]'],
-    'RdKafka\KafkaConsumer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\KafkaConsumerTopic', 'timeout_ms'=>'int'],
-    'RdKafka\KafkaConsumer::getSubscription' => ['array'],
-    'RdKafka\KafkaConsumer::subscribe' => ['void', 'topics'=>'array'],
-    'RdKafka\KafkaConsumer::unsubscribe' => ['void'],
-    'RdKafka\KafkaConsumerTopic::getName' => ['string'],
-    'RdKafka\KafkaConsumerTopic::offsetStore' => ['void', 'partition'=>'int', 'offset'=>'int'],
-    'RdKafka\Message::errstr' => ['string'],
-    'RdKafka\Metadata::getBrokers' => ['RdKafka\Metadata\Collection'],
-    'RdKafka\Metadata::getOrigBrokerId' => ['int'],
-    'RdKafka\Metadata::getOrigBrokerName' => ['string'],
-    'RdKafka\Metadata::getTopics' => ['RdKafka\Metadata\Collection|RdKafka\Metadata\Topic[]'],
-    'RdKafka\Metadata\Collection::__construct' => ['void'],
-    'RdKafka\Metadata\Collection::count' => ['int'],
-    'RdKafka\Metadata\Collection::current' => ['mixed'],
-    'RdKafka\Metadata\Collection::key' => ['mixed'],
-    'RdKafka\Metadata\Collection::next' => ['void'],
-    'RdKafka\Metadata\Collection::rewind' => ['void'],
-    'RdKafka\Metadata\Collection::valid' => ['bool'],
-    'RdKafka\Metadata\Partition::getErr' => ['mixed'],
-    'RdKafka\Metadata\Partition::getId' => ['int'],
-    'RdKafka\Metadata\Partition::getIsrs' => ['mixed'],
-    'RdKafka\Metadata\Partition::getLeader' => ['mixed'],
-    'RdKafka\Metadata\Partition::getReplicas' => ['mixed'],
-    'RdKafka\Metadata\Topic::getErr' => ['mixed'],
-    'RdKafka\Metadata\Topic::getPartitions' => ['RdKafka\Metadata\Partition[]'],
-    'RdKafka\Metadata\Topic::getTopic' => ['string'],
-    'RdKafka\Producer::__construct' => ['void', 'conf='=>'?RdKafka\Conf'],
-    'RdKafka\Producer::addBrokers' => ['int', 'broker_list'=>'string'],
-    'RdKafka\Producer::getMetadata' => ['RdKafka\Metadata', 'all_topics'=>'bool', 'only_topic='=>'?RdKafka\Topic', 'timeout_ms'=>'int'],
-    'RdKafka\Producer::getOutQLen' => ['int'],
-    'RdKafka\Producer::newQueue' => ['RdKafka\Queue'],
-    'RdKafka\Producer::newTopic' => ['RdKafka\ProducerTopic', 'topic_name'=>'string', 'topic_conf='=>'?RdKafka\TopicConf'],
-    'RdKafka\Producer::poll' => ['void', 'timeout_ms'=>'int'],
-    'RdKafka\Producer::setLogLevel' => ['void', 'level'=>'int'],
-    'RdKafka\ProducerTopic::__construct' => ['void'],
-    'RdKafka\ProducerTopic::getName' => ['string'],
-    'RdKafka\ProducerTopic::produce' => ['void', 'partition'=>'int', 'msgflags'=>'int', 'payload'=>'string', 'key='=>'?string'],
-    'RdKafka\ProducerTopic::producev' => ['void', 'partition'=>'int', 'msgflags'=>'int', 'payload'=>'string', 'key='=>'?string', 'headers='=>'?array<string, string>', 'timestamp_ms='=>'?int', 'opaque='=>'?string'],
-    'RdKafka\Queue::__construct' => ['void'],
-    'RdKafka\Queue::consume' => ['?RdKafka\Message', 'timeout_ms'=>'string'],
-    'RdKafka\Topic::getName' => ['string'],
-    'RdKafka\TopicConf::dump' => ['array<string, string>'],
-    'RdKafka\TopicConf::set' => ['void', 'name'=>'string', 'value'=>'string'],
-    'RdKafka\TopicConf::setPartitioner' => ['void', 'partitioner'=>'int'],
-    'RdKafka\TopicPartition::__construct' => ['void', 'topic'=>'string', 'partition'=>'int', 'offset='=>'int'],
-    'RdKafka\TopicPartition::getOffset' => ['int'],
-    'RdKafka\TopicPartition::getPartition' => ['int'],
-    'RdKafka\TopicPartition::getTopic' => ['string'],
-    'RdKafka\TopicPartition::setOffset' => ['void', 'offset'=>'string'],
-    'RdKafka\TopicPartition::setPartition' => ['void', 'partition'=>'string'],
-    'RdKafka\TopicPartition::setTopic' => ['void', 'topic_name'=>'string'],
     'RecursiveArrayIterator::__construct' => ['void', 'array='=>'array|object', 'flags='=>'int'],
     'RecursiveArrayIterator::append' => ['void', 'value'=>'mixed'],
     'RecursiveArrayIterator::asort' => ['true', 'flags='=>'int'],
@@ -13778,10 +13691,6 @@ return [
     'rar_wrapper_cache_stats' => ['string'],
     'rawurldecode' => ['string', 'string'=>'string'],
     'rawurlencode' => ['string', 'string'=>'string'],
-    'rd_kafka_err2str' => ['string', 'err'=>'int'],
-    'rd_kafka_errno' => ['int'],
-    'rd_kafka_errno2err' => ['int', 'errnox'=>'int'],
-    'rd_kafka_offset_tail' => ['int', 'cnt'=>'int'],
     'read_exif_data' => ['array', 'filename'=>'string', 'sections_needed='=>'string', 'sub_arrays='=>'bool', 'read_thumbnail='=>'bool'],
     'readdir' => ['string|false', 'dir_handle='=>'resource'],
     'readfile' => ['int|false', 'filename'=>'string', 'use_include_path='=>'bool', 'context='=>'resource'],
diff --git a/src/Psalm/Config.php b/src/Psalm/Config.php
index 0eaa9f837..c2a544773 100644
--- a/src/Psalm/Config.php
+++ b/src/Psalm/Config.php
@@ -631,6 +631,7 @@ class Config
         "mysqli" => null,
         "pdo" => null,
         "random" => null,
+        "rdkafka" => null,
         "redis" => null,
         "simplexml" => null,
         "soap" => null,
diff --git a/stubs/extensions/rdkafka.phpstub b/stubs/extensions/rdkafka.phpstub
new file mode 100644
index 000000000..af8c3a76e
--- /dev/null
+++ b/stubs/extensions/rdkafka.phpstub
@@ -0,0 +1,1195 @@
+<?php
+
+namespace {
+
+    const RD_KAFKA_RESP_ERR__BEGIN = -200;
+    const RD_KAFKA_RESP_ERR__BAD_MSG = -199;
+    const RD_KAFKA_RESP_ERR__BAD_COMPRESSION = -198;
+    const RD_KAFKA_RESP_ERR__DESTROY = -197;
+    const RD_KAFKA_RESP_ERR__FAIL = -196;
+    const RD_KAFKA_RESP_ERR__TRANSPORT = -195;
+    const RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194;
+    const RD_KAFKA_RESP_ERR__RESOLVE = -193;
+    const RD_KAFKA_RESP_ERR__MSG_TIMED_OUT = -192;
+    const RD_KAFKA_RESP_ERR__PARTITION_EOF = -191;
+    const RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION = -190;
+    const RD_KAFKA_RESP_ERR__FS = -189;
+    const RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC = -188;
+    const RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN = -187;
+    const RD_KAFKA_RESP_ERR__INVALID_ARG = -186;
+    const RD_KAFKA_RESP_ERR__TIMED_OUT = -185;
+    const RD_KAFKA_RESP_ERR__QUEUE_FULL = -184;
+    const RD_KAFKA_RESP_ERR__ISR_INSUFF = -183;
+    const RD_KAFKA_RESP_ERR__NODE_UPDATE = -182;
+    const RD_KAFKA_RESP_ERR__SSL = -181;
+    const RD_KAFKA_RESP_ERR__WAIT_COORD = -180;
+    const RD_KAFKA_RESP_ERR__UNKNOWN_GROUP = -179;
+    const RD_KAFKA_RESP_ERR__IN_PROGRESS = -178;
+    const RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS = -177;
+    const RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION = -176;
+    const RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS = -175;
+    const RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS = -174;
+    const RD_KAFKA_RESP_ERR__CONFLICT = -173;
+    const RD_KAFKA_RESP_ERR__STATE = -172;
+    const RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL = -171;
+    const RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170;
+    const RD_KAFKA_RESP_ERR__AUTHENTICATION = -169;
+    const RD_KAFKA_RESP_ERR__NO_OFFSET = -168;
+    const RD_KAFKA_RESP_ERR__OUTDATED = -167;
+    const RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE = -166;
+    const RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE = -165;
+    const RD_KAFKA_RESP_ERR__WAIT_CACHE = -164;
+    const RD_KAFKA_RESP_ERR__INTR = -163;
+    const RD_KAFKA_RESP_ERR__KEY_SERIALIZATION = -162;
+    const RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION = -161;
+    const RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION = -160;
+    const RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION = -159;
+    const RD_KAFKA_RESP_ERR__PARTIAL = -158;
+    const RD_KAFKA_RESP_ERR__READ_ONLY = -157;
+    const RD_KAFKA_RESP_ERR__NOENT = -156;
+    const RD_KAFKA_RESP_ERR__UNDERFLOW = -155;
+    const RD_KAFKA_RESP_ERR__INVALID_TYPE = -154;
+    const RD_KAFKA_RESP_ERR__RETRY = -153;
+    const RD_KAFKA_RESP_ERR__PURGE_QUEUE = -152;
+    const RD_KAFKA_RESP_ERR__PURGE_INFLIGHT = -151;
+    const RD_KAFKA_RESP_ERR__FATAL = -150;
+    const RD_KAFKA_RESP_ERR__INCONSISTENT = -149;
+    const RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE = -148;
+    const RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED = -147;
+    const RD_KAFKA_RESP_ERR__UNKNOWN_BROKER = -146;
+    const RD_KAFKA_RESP_ERR__NOT_CONFIGURED = -145;
+    const RD_KAFKA_RESP_ERR__FENCED = -144;
+    const RD_KAFKA_RESP_ERR__APPLICATION = -143;
+    const RD_KAFKA_RESP_ERR__ASSIGNMENT_LOST = -142;
+    const RD_KAFKA_RESP_ERR__NOOP = -141;
+    const RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET = -140;
+    const RD_KAFKA_RESP_ERR__END = -100;
+    const RD_KAFKA_RESP_ERR_UNKNOWN = -1;
+    const RD_KAFKA_RESP_ERR_NO_ERROR = 0;
+    const RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE = 1;
+    const RD_KAFKA_RESP_ERR_INVALID_MSG = 2;
+    const RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART = 3;
+    const RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE = 4;
+    const RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE = 5;
+    const RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION = 6;
+    const RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT = 7;
+    const RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE = 8;
+    const RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE = 9;
+    const RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE = 10;
+    const RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH = 11;
+    const RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE = 12;
+    const RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION = 13;
+    const RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS = 14;
+    const RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE = 15;
+    const RD_KAFKA_RESP_ERR_NOT_COORDINATOR = 16;
+    const RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS = 14; // alias, RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS
+    const RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE = 15; // alias, RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE
+    const RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP = 16; // alias, RD_KAFKA_RESP_ERR_NOT_COORDINATOR
+    const RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION = 17;
+    const RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE = 18;
+    const RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS = 19;
+    const RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND = 20;
+    const RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS = 21;
+    const RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION = 22;
+    const RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL = 23;
+    const RD_KAFKA_RESP_ERR_INVALID_GROUP_ID = 24;
+    const RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID = 25;
+    const RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT = 26;
+    const RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS = 27;
+    const RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE = 28;
+    const RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED = 29;
+    const RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED = 30;
+    const RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED = 31;
+    const RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP = 32;
+    const RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM = 33;
+    const RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE = 34;
+    const RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION = 35;
+    const RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS = 36;
+    const RD_KAFKA_RESP_ERR_INVALID_PARTITIONS = 37;
+    const RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR = 38;
+    const RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT = 39;
+    const RD_KAFKA_RESP_ERR_INVALID_CONFIG = 40;
+    const RD_KAFKA_RESP_ERR_NOT_CONTROLLER = 41;
+    const RD_KAFKA_RESP_ERR_INVALID_REQUEST = 42;
+    const RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT = 43;
+    const RD_KAFKA_RESP_ERR_POLICY_VIOLATION = 44;
+    const RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER = 45;
+    const RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER = 46;
+    const RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH = 47;
+    const RD_KAFKA_RESP_ERR_INVALID_TXN_STATE = 48;
+    const RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING = 49;
+    const RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT = 50;
+    const RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51;
+    const RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED = 52;
+    const RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED = 53;
+    const RD_KAFKA_RESP_ERR_SECURITY_DISABLED = 54;
+    const RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED = 55;
+    const RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR = 56;
+    const RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND = 57;
+    const RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED = 58;
+    const RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID = 59;
+    const RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS = 60;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED = 61;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND = 62;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH = 63;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED = 64;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED = 65;
+    const RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED = 66;
+    const RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE = 67;
+    const RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP = 68;
+    const RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND = 69;
+    const RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND = 70;
+    const RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH = 71;
+    const RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND = 72;
+    const RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED = 73;
+    const RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH = 74;
+    const RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH = 75;
+    const RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE = 76;
+    const RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH = 77;
+    const RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE = 78;
+    const RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED = 79;
+    const RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE = 80;
+    const RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED = 81;
+    const RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID = 82;
+    const RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE = 83;
+    const RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED = 84;
+    const RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS = 85;
+    const RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC = 86;
+    const RD_KAFKA_RESP_ERR_INVALID_RECORD = 87;
+    const RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT = 88;
+    const RD_KAFKA_RESP_ERR_THROTTLING_QUOTA_EXCEEDED = 89;
+    const RD_KAFKA_RESP_ERR_PRODUCER_FENCED = 90;
+    const RD_KAFKA_RESP_ERR_RESOURCE_NOT_FOUND = 91;
+    const RD_KAFKA_RESP_ERR_DUPLICATE_RESOURCE = 92;
+    const RD_KAFKA_RESP_ERR_UNACCEPTABLE_CREDENTIAL = 93;
+    const RD_KAFKA_RESP_ERR_INCONSISTENT_VOTER_SET = 94;
+    const RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION = 95;
+    const RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED = 96;
+    const RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97;
+    const RD_KAFKA_CONSUMER = 1;
+    const RD_KAFKA_OFFSET_BEGINNING = -2;
+    const RD_KAFKA_OFFSET_END = -1;
+    const RD_KAFKA_OFFSET_STORED = -1000;
+    const RD_KAFKA_OFFSET_INVALID = -1001;
+    const RD_KAFKA_PARTITION_UA = -1;
+    const RD_KAFKA_PRODUCER = 0;
+    const RD_KAFKA_VERSION = 525568;
+    const RD_KAFKA_BUILD_VERSION = 17236223;
+    const RD_KAFKA_CONF_UNKNOWN = -2;
+    const RD_KAFKA_CONF_INVALID = -1;
+    const RD_KAFKA_CONF_OK = 0;
+    const RD_KAFKA_MSG_PARTITIONER_RANDOM = 2;
+    const RD_KAFKA_MSG_PARTITIONER_CONSISTENT = 3;
+    const RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM = 4;
+    const RD_KAFKA_MSG_PARTITIONER_MURMUR2 = 5;
+    const RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM = 6;
+    const RD_KAFKA_LOG_PRINT = 100;
+    const RD_KAFKA_LOG_SYSLOG = 101;
+    const RD_KAFKA_LOG_SYSLOG_PRINT = 102;
+    const RD_KAFKA_PURGE_F_QUEUE = 1;
+    const RD_KAFKA_PURGE_F_INFLIGHT = 2;
+    const RD_KAFKA_PURGE_F_NON_BLOCKING = 4;
+    const RD_KAFKA_MSG_F_BLOCK = 4;
+
+    /**
+     * @param int $err Error code
+     *
+     * @return string Returns the error as a string.
+     */
+    function rd_kafka_err2str($err)
+    {
+    }
+
+    /**
+     * @param int $errnox A system errno
+     *
+     * @return int Returns a kafka error code as an integer.
+     */
+    function rd_kafka_errno2err($errnox)
+    {
+    }
+
+    /**
+     * @return int Returns the system errno as an integer.
+     */
+    function rd_kafka_errno()
+    {
+    }
+
+    /**
+     * @param int $cnt
+     *
+     * @return int Returns the special offset as an integer.
+     */
+    function rd_kafka_offset_tail($cnt)
+    {
+    }
+
+    abstract class RdKafka
+    {
+        /**
+         * @param string $broker_list
+         *
+         * @return int
+         */
+        public function addBrokers($broker_list)
+        {
+        }
+
+        /**
+         * @param bool $all_topics
+         * @param \RdKafka\Topic|null $only_topic
+         * @param int $timeout_ms
+         *
+         * @return \RdKafka\Metadata
+         * @throws \RdKafka\Exception
+         */
+        public function getMetadata($all_topics, $only_topic = null, $timeout_ms)
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function getOutQLen()
+        {
+        }
+
+        /**
+         * @param string $topic_name
+         * @param \RdKafka\TopicConf $topic_conf
+         *
+         * @return \RdKafka\Topic
+         */
+        public function newTopic($topic_name, TopicConf $topic_conf = null)
+        {
+        }
+
+        /**
+         * @param int $timeout_ms
+         *
+         * @return void
+         */
+        public function poll($timeout_ms)
+        {
+        }
+
+        /**
+         * @param int $level
+         *
+         * @return void
+         * @deprecated
+         *
+         */
+        public function setLogLevel($level)
+        {
+        }
+
+        /**
+         * @param string $topic
+         * @param int $partition
+         * @param int $low
+         * @param int $high
+         * @param int $timeout_ms
+         */
+        public function queryWatermarkOffsets($topic, $partition, &$low, &$high, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param array $topicPartitions
+         * @param int $timeout_ms
+         * @return array
+         */
+        public function offsetsForTimes($topicPartitions, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param int $purge_flags
+         * @return int
+         */
+        public function purge($purge_flags)
+        {
+        }
+
+        /**
+         * @param int $timeout_ms
+         * @return int
+         */
+        public function flush($timeout_ms)
+        {
+        }
+    }
+}
+
+namespace RdKafka {
+
+    class Conf
+    {
+        /**
+         * @return array<string, string>
+         */
+        public function dump()
+        {
+        }
+
+        /**
+         * @param string $name
+         * @param string $value
+         *
+         * @return void
+         */
+        public function set($name, $value)
+        {
+        }
+
+        /**
+         * @param TopicConf $topic_conf
+         *
+         * @return void
+         * @deprecated Set default topic settings normally like global configuration settings.
+         *
+         */
+        public function setDefaultTopicConf(TopicConf $topic_conf)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setDrMsgCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setErrorCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setRebalanceCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setStatsCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setConsumeCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setOffsetCommitCb(callable $callback)
+        {
+        }
+
+        /**
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function setLogCb(callable $callback)
+        {
+        }
+    }
+
+    class Consumer extends \RdKafka
+    {
+        /**
+         * @param Conf $conf
+         */
+        public function __construct(Conf $conf = null)
+        {
+        }
+
+        /**
+         * @param string $topic_name
+         * @param TopicConf $topic_conf
+         *
+         * @return ConsumerTopic
+         */
+        public function newTopic($topic_name, TopicConf $topic_conf = null)
+        {
+        }
+
+        /**
+         * @return Queue
+         */
+        public function newQueue()
+        {
+        }
+    }
+
+    class ConsumerTopic extends Topic
+    {
+        private function __construct()
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $timeout_ms
+         *
+         * @return Message|null
+         */
+        public function consume($partition, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $offset
+         * @param Queue $queue
+         *
+         * @return void
+         */
+        public function consumeQueueStart($partition, $offset, Queue $queue)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $offset
+         *
+         * @return void
+         */
+        public function consumeStart($partition, $offset)
+        {
+        }
+
+        /**
+         * @param int $partition
+         *
+         * @return void
+         */
+        public function consumeStop($partition)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $offset
+         *
+         * @return void
+         */
+        public function offsetStore($partition, $offset)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $timeout_ms
+         * @param int $batch_size
+         *
+         * @return array
+         * @throws \InvalidArgumentException
+         * @throws Exception
+         */
+        public function consumeBatch($partition, $timeout_ms, $batch_size)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $timeout_ms
+         * @param callable $callback
+         *
+         * @return void
+         */
+        public function consumeCallback($partition, $timeout_ms, callable $callback)
+        {
+        }
+    }
+
+    class Exception extends \Exception
+    {
+    }
+
+    class KafkaConsumer
+    {
+        /**
+         * @param Conf $conf
+         */
+        public function __construct(Conf $conf)
+        {
+        }
+
+        /**
+         * @param TopicPartition[] $topic_partitions
+         *
+         * @return void
+         * @throws Exception
+         */
+        public function assign($topic_partitions = null)
+        {
+        }
+
+        /**
+         * @param null|Message|TopicPartition[] $message_or_offsets
+         *
+         * @return void
+         * @throws Exception
+         */
+        public function commit($message_or_offsets = null)
+        {
+        }
+
+        /**
+         * @param string $message_or_offsets
+         *
+         * @return void
+         * @throws Exception
+         */
+        public function commitAsync($message_or_offsets = null)
+        {
+        }
+
+        /**
+         * @param int $timeout_ms
+         *
+         * @return Message
+         * @throws \InvalidArgumentException
+         * @throws Exception
+         */
+        public function consume($timeout_ms)
+        {
+        }
+
+        /**
+         * @return TopicPartition[]
+         * @throws Exception
+         */
+        public function getAssignment()
+        {
+        }
+
+        /**
+         * @param bool $all_topics
+         * @param KafkaConsumerTopic|null $only_topic
+         * @param int $timeout_ms
+         *
+         * @return Metadata
+         * @throws Exception
+         */
+        public function getMetadata($all_topics, $only_topic, $timeout_ms)
+        {
+        }
+
+        /**
+         * @return array
+         */
+        public function getSubscription()
+        {
+        }
+
+        /**
+         * @param string $topic_name
+         * @param TopicConf $topic_conf
+         *
+         * @return KafkaConsumerTopic
+         */
+        public function newTopic($topic_name, TopicConf $topic_conf = null)
+        {
+        }
+
+        /**
+         * @param array $topics
+         *
+         * @return void
+         * @throws Exception
+         */
+        public function subscribe($topics)
+        {
+        }
+
+        /**
+         * @return void
+         * @throws Exception
+         */
+        public function unsubscribe()
+        {
+        }
+
+        /**
+         * @param TopicPartition[] $topicPartitions
+         * @param int $timeout_ms Timeout in milliseconds
+         *
+         * @return TopicPartition[]
+         * @throws Exception
+         */
+        public function getCommittedOffsets($topicPartitions, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param array $topicPartitions
+         * @param int $timeout_ms
+         * @return array
+         */
+        public function offsetsForTimes($topicPartitions, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param string $topic
+         * @param int $partition
+         * @param int $low
+         * @param int $high
+         * @param int $timeout_ms
+         */
+        public function queryWatermarkOffsets($topic, $partition, &$low, &$high, $timeout_ms)
+        {
+        }
+
+        /**
+         * @param array $topics
+         *
+         * @return array
+         * @throws Exception
+         */
+        public function getOffsetPositions($topics)
+        {
+        }
+
+        /**
+         * @return void
+         */
+        public function close()
+        {
+        }
+
+        /**
+         * @param TopicPartition[] $topic_partitions
+         * @return TopicPartition[]
+         */
+        public function pausePartitions($topic_partitions)
+        {
+        }
+
+        /**
+         * @param TopicPartition[] $topic_partitions
+         * @return TopicPartition[]
+         */
+        public function resumePartitions($topic_partitions)
+        {
+        }
+    }
+
+    class KafkaConsumerTopic extends Topic
+    {
+        /**
+         * @param int $partition
+         * @param int $offset
+         *
+         * @return void
+         */
+        public function offsetStore($partition, $offset)
+        {
+        }
+    }
+
+    class KafkaErrorException extends \Exception
+    {
+        /**
+         * @param string $message
+         * @param int $code
+         * @param string $errorString
+         * @param boolean $isFatal
+         * @param boolean $isRetriable
+         * @param boolean $transactionRequiresAbort
+         */
+        public function __construct($message, $code, $errorString, $isFatal, $isRetriable, $transactionRequiresAbort)
+        {
+            parent::__construct($message, $code);
+        }
+
+        /**
+         * @returns string
+         */
+        public function getErrorString()
+        {
+        }
+
+        /**
+         * @returns boolean
+         */
+        public function isFatal()
+        {
+        }
+
+        /**
+         * @returns boolean
+         */
+        public function isRetriable()
+        {
+        }
+
+        /**
+         * @returns boolean
+         */
+        public function transactionRequiresAbort()
+        {
+        }
+    }
+
+    class Message
+    {
+        /**
+         * @var int
+         */
+        public $err;
+
+        /**
+         * @var string
+         */
+        public $topic_name;
+
+        /**
+         * @var int
+         */
+        public $partition;
+
+        /**
+         * @var string|null
+         */
+        public $payload;
+
+        /**
+         * @var int|null
+         */
+        public $len;
+
+        /**
+         * @var string|null
+         */
+        public $key;
+
+        /**
+         * @var int
+         */
+        public $offset;
+
+        /**
+         * @var int
+         */
+        public $timestamp;
+
+        /**
+         * @var array|null
+         */
+        public $headers;
+
+        /**
+         * @var string|null
+         */
+        public $opaque;
+
+        /**
+         * @return string
+         */
+        public function errstr()
+        {
+        }
+    }
+
+    class Metadata
+    {
+        /**
+         * @return \RdKafka\Metadata\Collection|\RdKafka\Metadata\Broker[]
+         */
+        public function getBrokers()
+        {
+        }
+
+        /**
+         * @return \RdKafka\Metadata\Collection|\RdKafka\Metadata\Topic[]
+         */
+        public function getTopics()
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function getOrigBrokerId()
+        {
+        }
+
+        /**
+         * @return string
+         */
+        public function getOrigBrokerName()
+        {
+        }
+    }
+
+    class Producer extends \RdKafka
+    {
+        /**
+         * @param Conf $conf
+         */
+        public function __construct(Conf $conf = null)
+        {
+        }
+
+        /**
+         * @param string $topic_name
+         * @param TopicConf $topic_conf
+         *
+         * @return ProducerTopic
+         */
+        public function newTopic($topic_name, TopicConf $topic_conf = null)
+        {
+        }
+
+        /**
+         * @param int $timeoutMs
+         *
+         * @return void
+         * @throws KafkaErrorException
+         */
+        public function initTransactions(int $timeoutMs)
+        {
+        }
+
+        /**
+         * @return void
+         * @throws KafkaErrorException
+         */
+        public function beginTransaction()
+        {
+        }
+
+        /**
+         * @param int $timeoutMs
+         *
+         * @return void
+         * @throws KafkaErrorException
+         */
+        public function commitTransaction(int $timeoutMs)
+        {
+        }
+
+        /**
+         * @param int $timeoutMs
+         *
+         * @return void
+         * @throws KafkaErrorException
+         */
+        public function abortTransaction(int $timeoutMs)
+        {
+        }
+    }
+
+    class ProducerTopic extends Topic
+    {
+        private function __construct()
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $msgflags
+         * @param string $payload
+         * @param string $key
+         *
+         * @return void
+         * @throws Exception
+         */
+        public function produce($partition, $msgflags, $payload, $key = null)
+        {
+        }
+
+        /**
+         * @param int $partition
+         * @param int $msgflags
+         * @param string $payload
+         * @param string|null $key
+         * @param array|null $headers
+         * @param int $timestamp_ms
+         *
+         * @throws Exception
+         */
+        public function producev($partition, $msgflags, $payload, $key = null, $headers = null, $timestamp_ms = null)
+        {
+        }
+    }
+
+    class Queue
+    {
+        private function __construct()
+        {
+        }
+
+        /**
+         * @param string $timeout_ms
+         *
+         * @return Message|null
+         */
+        public function consume($timeout_ms)
+        {
+        }
+    }
+
+    abstract class Topic
+    {
+        /**
+         * @return string
+         */
+        public function getName()
+        {
+        }
+    }
+
+    /**
+     * Configuration reference: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
+     */
+    class TopicConf
+    {
+        /**
+         * @return array
+         */
+        public function dump()
+        {
+        }
+
+        /**
+         * @param string $name
+         * @param string $value
+         *
+         * @return void
+         */
+        public function set($name, $value)
+        {
+        }
+
+        /**
+         * @param int $partitioner
+         *
+         * @return void
+         */
+        public function setPartitioner($partitioner)
+        {
+        }
+    }
+
+    class TopicPartition
+    {
+        /**
+         * @param string $topic
+         * @param int $partition
+         * @param int $offset
+         */
+        public function __construct($topic, $partition, $offset = null)
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function getOffset()
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function getPartition()
+        {
+        }
+
+        /**
+         * @return string
+         */
+        public function getTopic()
+        {
+        }
+
+        /**
+         * @param int $offset
+         *
+         * @return void
+         */
+        public function setOffset($offset)
+        {
+        }
+
+        /**
+         * @param int $partition
+         *
+         * @return void
+         */
+        public function setPartition($partition)
+        {
+        }
+
+        /**
+         * @param string $topic_name
+         *
+         * @return void
+         */
+        public function setTopic($topic_name)
+        {
+        }
+    }
+}
+
+namespace RdKafka\Metadata {
+
+    class Broker
+    {
+        /**
+         * @return int
+         */
+        public function getId()
+        {
+        }
+
+        /**
+         * @return string
+         */
+        public function getHost()
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function getPort()
+        {
+        }
+    }
+
+    class Collection implements \Iterator, \Countable
+    {
+        /**
+         * @return mixed
+         */
+        public function current()
+        {
+        }
+
+        /**
+         * @return void
+         */
+        public function next()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function key()
+        {
+        }
+
+        /**
+         * @return boolean
+         */
+        public function valid()
+        {
+        }
+
+        /**
+         * @return void
+         */
+        public function rewind()
+        {
+        }
+
+        /**
+         * @return int
+         */
+        public function count()
+        {
+        }
+    }
+
+    class Partition
+    {
+        /**
+         * @return int
+         */
+        public function getId()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function getErr()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function getLeader()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function getReplicas()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function getIsrs()
+        {
+        }
+    }
+
+    class Topic
+    {
+        /**
+         * @return string
+         */
+        public function getTopic()
+        {
+        }
+
+        /**
+         * @return Partition[]
+         */
+        public function getPartitions()
+        {
+        }
+
+        /**
+         * @return mixed
+         */
+        public function getErr()
+        {
+        }
+    }
+}
\ No newline at end of file