update stubs to rdkafka:4.1

PhpStormStubsMap.php

@@ -583,6 +583,7 @@ final class PhpStormStubsMap
   'RdKafka\\Exception' => 'rdkafka/RdKafka/Exception.php',
   'RdKafka\\KafkaConsumer' => 'rdkafka/RdKafka/KafkaConsumer.php',
   'RdKafka\\KafkaConsumerTopic' => 'rdkafka/RdKafka/KafkaConsumerTopic.php',
+  'RdKafka\\KafkaErrorException' => 'rdkafka/RdKafka/KafkaErrorException.php',
   'RdKafka\\Message' => 'rdkafka/RdKafka/Message.php',
   'RdKafka\\Metadata' => 'rdkafka/RdKafka/Metadata.php',
   'RdKafka\\Metadata\\Collection' => 'rdkafka/RdKafka/Metadata/Collection.php',

rdkafka/RdKafka/KafkaErrorException.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace RdKafka;
+
+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)
+    {
+    }
+
+    /**
+     * @returns string
+     */
+    public function getErrorString()
+    {
+    }
+
+    /**
+     * @returns boolean
+     */
+    public function isFatal()
+    {
+    }
+
+    /**
+     * @returns boolean
+     */
+    public function isRetriable()
+    {
+    }
+
+    /**
+     * @returns boolean
+     */
+    public function transactionRequiresAbort()
+    {
+    }
+}

rdkafka/RdKafka/Producer.php

@@ -20,4 +20,38 @@ public function __construct(Conf $conf = null)
     public function newTopic($topic_name, ?TopicConf $topic_conf = null)
     {
     }
+
+    /**
+     * @param int $timeoutMs
+     *
+     * @return void
+     */
+    public function initTransactions(int $timeoutMs)
+    {
+    }
+
+    /**
+     * @return void
+     */
+    public function beginTransaction()
+    {
+    }
+
+    /**
+     * @param int $timeoutMs
+     *
+     * @return void
+     */
+    public function commitTransaction(int $timeoutMs)
+    {
+    }
+
+    /**
+     * @param int $timeoutMs
+     *
+     * @return void
+     */
+    public function abortTransaction(int $timeoutMs)
+    {
+    }
 }