adding missing throws (#43)

Author: damianwadley

stubs/RdKafka/ConsumerTopic.php

@@ -62,6 +62,9 @@ public function offsetStore($partition, $offset)
      * @param int $partition
      * @param int $timeout_ms
      * @param int $batch_size
+     *
+     * @throws Exception
+     * @throws \InvalidArgumentException
      * @return array
      */
     public function consumeBatch($partition, $timeout_ms, $batch_size)

stubs/RdKafka/KafkaConsumer.php

@@ -130,6 +130,8 @@ public function queryWatermarkOffsets($topic, $partition, &$low, &$high, $timeou
 
     /**
      * @param array $topics
+     *
+     * @throws Exception
      * @return array
      */
     public function getOffsetPositions($topics)

stubs/RdKafka/Producer.php

@@ -24,13 +24,15 @@ public function newTopic($topic_name, TopicConf $topic_conf = null)
     /**
      * @param int $timeoutMs
      *
+     * @throws KafkaErrorException
      * @return void
      */
     public function initTransactions(int $timeoutMs)
     {
     }
 
     /**
+     * @throws KafkaErrorException
      * @return void
      */
     public function beginTransaction()
@@ -40,6 +42,7 @@ public function beginTransaction()
     /**
      * @param int $timeoutMs
      *
+     * @throws KafkaErrorException
      * @return void
      */
     public function commitTransaction(int $timeoutMs)
@@ -49,6 +52,7 @@ public function commitTransaction(int $timeoutMs)
     /**
      * @param int $timeoutMs
      *
+     * @throws KafkaErrorException
      * @return void
      */
     public function abortTransaction(int $timeoutMs)

stubs/RdKafka/ProducerTopic.php

@@ -14,6 +14,7 @@ private function __construct()
      * @param string $payload
      * @param string $key
      *
+     * @throws Exception
      * @return void
      */
     public function produce($partition, $msgflags, $payload, $key = null)
@@ -27,6 +28,8 @@ public function produce($partition, $msgflags, $payload, $key = null)
      * @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)
     {