From daa6db8a333082b28998dfb3b12c8c62f69a0bf7 Mon Sep 17 00:00:00 2001
From: DigitVE <etercalm93@gmail.com>
Date: Tue, 13 Jul 2021 23:26:58 +0300
Subject: [PATCH] Added getter for offset field in RdKafkaConsumer class

---
 pkg/rdkafka/RdKafkaConsumer.php | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pkg/rdkafka/RdKafkaConsumer.php b/pkg/rdkafka/RdKafkaConsumer.php
index 3aa568edb..7fbaef755 100644
--- a/pkg/rdkafka/RdKafkaConsumer.php
+++ b/pkg/rdkafka/RdKafkaConsumer.php
@@ -66,6 +66,11 @@ public function setCommitAsync(bool $async): void
         $this->commitAsync = $async;
     }
 
+    public function getOffset(): ?int
+    {
+        return $this->offset;
+    }
+
     public function setOffset(int $offset = null): void
     {
         if ($this->subscribed) {