From 3edb7c986fb5c101a63dbf76d5c697debaf6a459 Mon Sep 17 00:00:00 2001
From: Tony-Sol <tony.kent.nar.earth@gmail.com>
Date: Wed, 8 Jun 2022 19:19:31 +0300
Subject: [PATCH] Actualize ConsumerTopic, KafkaConsumer, KafkaConsumerTopic,
 Message

---
 stubs/RdKafka/ConsumerTopic.php      | 11 +++++++++++
 stubs/RdKafka/KafkaConsumer.php      | 26 ++++++++++++++++++++++++++
 stubs/RdKafka/KafkaConsumerTopic.php | 11 -----------
 stubs/RdKafka/Message.php            | 10 ++++++++++
 4 files changed, 47 insertions(+), 11 deletions(-)

diff --git a/stubs/RdKafka/ConsumerTopic.php b/stubs/RdKafka/ConsumerTopic.php
index 8c1dfca..3878e22 100644
--- a/stubs/RdKafka/ConsumerTopic.php
+++ b/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)
+    {
+    }
 }
diff --git a/stubs/RdKafka/KafkaConsumer.php b/stubs/RdKafka/KafkaConsumer.php
index e19601e..c34f0f4 100644
--- a/stubs/RdKafka/KafkaConsumer.php
+++ b/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)
+    {
+    }
 }
diff --git a/stubs/RdKafka/KafkaConsumerTopic.php b/stubs/RdKafka/KafkaConsumerTopic.php
index 134cd8b..89d29cb 100644
--- a/stubs/RdKafka/KafkaConsumerTopic.php
+++ b/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)
-    {
-    }
 }
diff --git a/stubs/RdKafka/Message.php b/stubs/RdKafka/Message.php
index 892cee9..901f1f6 100644
--- a/stubs/RdKafka/Message.php
+++ b/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
      */