update stubs for 4.0 (#24)

* update stubs for 4.0

* move offset positions to right place

* throw exceptions on deprecated functions

* expect deprecated

* remove return types

* remove function typeremove function types

* update ext version

composer.json

@@ -9,7 +9,7 @@
         }
     ],
     "require": {
-        "ext-rdkafka": ">=3.1"
+        "ext-rdkafka": ">=4.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^8.2.4"

stubs/RdKafka.php

@@ -36,13 +36,6 @@ public function getOutQLen()
     {
     }
 
-    /**
-     * @return Queue
-     */
-    public function newQueue()
-    {
-    }
-
     /**
      * @param string    $topic_name
      * @param TopicConf $topic_conf
@@ -81,4 +74,29 @@ public function setLogLevel($level)
     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)
+    {
+    }
 }

stubs/RdKafka/Conf.php

@@ -86,4 +86,13 @@ public function setConsumeCb(callable $callback)
     public function setOffsetCommitCb(callable $callback)
     {
     }
+
+    /**
+     * @param callable $callback
+     *
+     * @return void
+     */
+    public function setLogCb(callable $callback)
+    {
+    }
 }

stubs/RdKafka/Consumer.php

@@ -20,4 +20,11 @@ public function __construct(Conf $conf = null)
     public function newTopic($topic_name, TopicConf $topic_conf = null)
     {
     }
+
+    /**
+     * @return Queue
+     */
+    public function newQueue()
+    {
+    }
 }

stubs/RdKafka/ConsumerTopic.php

@@ -57,4 +57,14 @@ public function consumeStop($partition)
     public function offsetStore($partition, $offset)
     {
     }
+
+    /**
+     * @param int $partition
+     * @param int $timeout_ms
+     * @param int $batch_size
+     * @return array
+     */
+    public function consumeBatch($partition, $timeout_ms, $batch_size)
+    {
+    }
 }

stubs/RdKafka/KafkaConsumer.php

@@ -104,4 +104,39 @@ public function unsubscribe()
     public function getCommittedOffsets($topics, $timeout)
     {
     }
+
+    /**
+     * @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
+     */
+    public function getOffsetPositions($topics)
+    {
+    }
+
+    /**
+     * @return void
+     */
+    public function close()
+    {
+    }
 }

stubs/constants.php

@@ -111,8 +111,15 @@
 const RD_KAFKA_CONF_UNKNOWN = -2;
 const RD_KAFKA_CONF_INVALID = -1;
 const RD_KAFKA_CONF_OK = 0;
-const RD_KAFKA_MSG_PARTITIONER_RANDOM = 0;
-const RD_KAFKA_MSG_PARTITIONER_CONSISTENT = 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 = 0;
 const RD_KAFKA_LOG_SYSLOG = 0;
 const RD_KAFKA_LOG_SYSLOG_PRINT = 0;
+const RD_KAFKA_PURGE_F_QUEUE = 0x1;
+const RD_KAFKA_PURGE_F_INFLIGHT = 0x2;
+const RD_KAFKA_PURGE_F_NON_BLOCKING = 0x4;
+const RD_KAFKA_MSG_F_BLOCK = 0x4;

tests/RdKafka/ConsumerTest.php

@@ -2,6 +2,7 @@
 
 namespace RdKafka;
 
+use PHPUnit\Framework\Error\Deprecated;
 use PHPUnit\Framework\TestCase;
 
 class ConsumerTest extends TestCase
@@ -69,6 +70,8 @@ public function testPoll()
 
     public function testSetLogLevel()
     {
+        $this->expectException(Deprecated::class);
+
         $this->consumer->setLogLevel(LOG_DEBUG);
 
         $this->markTestIncomplete('Create real test');

tests/RdKafka/ProducerTest.php

@@ -2,6 +2,7 @@
 
 namespace RdKafka;
 
+use PHPUnit\Framework\Error\Deprecated;
 use PHPUnit\Framework\TestCase;
 
 class ProducerTest extends TestCase
@@ -75,6 +76,8 @@ public function testPoll()
 
     public function testSetLogLevel()
     {
+        $this->expectException(Deprecated::class);
+
         $this->producer->setLogLevel(LOG_DEBUG);
 
         self::markTestIncomplete('Create real test');