Actualize ConsumerTopic, KafkaConsumer, KafkaConsumerTopic, Message (#46)

Author: tony-sol

stubs/RdKafka/ConsumerTopic.php

@@ -70,4 +70,15 @@ public function offsetStore($partition, $offset)
     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)
+    {
+    }
 }

stubs/RdKafka/KafkaConsumer.php

@@ -79,6 +79,16 @@ 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
      *
@@ -144,4 +154,20 @@ public function getOffsetPositions($topics)
     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)
+    {
+    }
 }

stubs/RdKafka/KafkaConsumerTopic.php

@@ -13,15 +13,4 @@ class KafkaConsumerTopic extends Topic
     public function offsetStore($partition, $offset)
     {
     }
-
-    /**
-     * @param int $partition
-     * @param int $timeout_ms
-     * @param callable $callback
-     *
-     * @return void
-     */
-    public function consumeCallback($partition, $timeout_ms, callable $callback)
-    {
-    }
 }

stubs/RdKafka/Message.php

@@ -24,6 +24,11 @@ class Message
      */
     public $payload;
 
+    /**
+     * @var int|null
+     */
+    public $len;
+
     /**
      * @var string|null
      */
@@ -44,6 +49,11 @@ class Message
      */
     public $headers;
 
+    /**
+     * @var string|null
+     */
+    public $opaque;
+
     /**
      * @return string
      */