From 240b27d9847df23e8b1921059a9118fd8931534b Mon Sep 17 00:00:00 2001
From: Frank de Jonge <frank.de.jonge@mollie.com>
Date: Fri, 5 Jun 2020 15:49:17 +0200
Subject: [PATCH] Added queryWatermarkOffsets and offsetsForTimes for the
 RdKafka\KafkaConsumer class

---
 rdkafka/RdKafka/KafkaConsumer.php | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/rdkafka/RdKafka/KafkaConsumer.php b/rdkafka/RdKafka/KafkaConsumer.php
index 479e017e..afc1a5f3 100755
--- a/rdkafka/RdKafka/KafkaConsumer.php
+++ b/rdkafka/RdKafka/KafkaConsumer.php
@@ -106,4 +106,27 @@ class KafkaConsumer
     public function getCommittedOffsets(array $topics, int $timeout_ms)
     {
     }
+
+    /**
+     * @param TopicPartition[] $topicPartitions
+     * @param int $timeout_ms
+     *
+     * @return TopicPartition[]
+     */
+    public function offsetsForTimes(array $topicPartitions, int $timeout_ms)
+    {
+    }
+
+    /**
+     * @param string $topic
+     * @param int $partition
+     * @param int $low
+     * @param int $high
+     * @param int $timeout_ms
+     *
+     * @return void
+     */
+    public function queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeout_ms)
+    {
+    }
 }